So, in order to work with event time I have to options, inside kafka consumer or after kafka consumer. The first I can use: FlinkKafkaConsumer09<DataParameterMap> consumer..... consumer. assignTimestampsAndWatermarks()
The other option: FlinkKafkaConsumer09<DataParameterMap> consumer..... DataStream dataStream =env.addSource(consumer); dataStream. assignTimestampsAndWatermarks() Any recommendation? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Kafka-watermarks-tp13849p13872.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
