Skip to content

kafka_source - add ability to parse timestamp from str

Ottomata requested to merge kafka_offset_timestamp into main

This is needed especially if the offsets_initializer is parsed from config SourceDescriptor options, which by default is parsed as a str.

I will use this to do more stress testing, but starting from a dayish ago, rather than having to reprocess a full week.

Merge request reports