Hi, I am having a pipeline where source and sink are two Kafka topics. The pipeline uses event time semantics, where event time is extracted from the record.
What I notice is that when producing records at the sink side, it produces them such that the record's time in the kafka topic is the same as its event time. Ideally I was expecting that the record's time should be the timestamp when the record was inserted in the Kafka topic and not the same as its event time. How can I control this behaviour? Thanks Sachin
