Almost working with intervals
Now works with sources that don't have WhenPublishedToKafka keys in their JSON