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 you epoch creation time but not sure how to do it programmatically. The second question is since my processing won't be based on the event timestamp (but there is a need to append it to the records) do I need to explicitly mention WatermarkStrategy.noWatermarks()? TIA, P
