Hello experts,
My source is Kafka and I am trying to generate records for which I have
FlinkKafkaConsumer class.
Now my first question is how to consume an event timestamp for the records
generated.
I know for a fact that for CLI, there is one property called
*print.timestamp=true* which gives yo
hi Sid
1. You can customize KafkaDeserializationSchema[1], in the `deserialize`
method, you can obtain the Kafka event time.
2. I don't think it's necessary to explicitly mention the watermark
strategy.
[1].
https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/connec
