Skip to content

Do not override producer events dt

DCausse requested to merge do-not-override-producer-events-dt-field into main

The use of KafkaRecordTimestampStrategy.FLINK_RECORD_EVENT_TIME will override the dt field with the timestamp found in the flink records. But because we use a window the timestamp is set on the results to the end of the window which is no longer the actual event-time. Tell the sink to trust the dt field we set and progapate from the sources.

Bug: T328330 Change-Id: Ie91bd8a9c7e5cd7cdb8fc986221a134db3e105d2

Merge request reports