Hi Archit! You’ll need to assign timestamps to the records in your stream before producing them to Kafka (i.e. before the FlinkKafkaProducer operator). Have a look at [1] and [2] on how to do that. Feel free to ask further questions if you bump into any!
Cheers, Gordon [1] https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/event_timestamps_watermarks.html [2] https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/event_timestamp_extractors.html On April 2, 2017 at 6:38:13 PM, Archit Mittal ([email protected]) wrote: Hi I am using flink-connector-kafka-0.10_2.10 while producing i am getting error as java.lang.IllegalArgumentException: Invalid timestamp -9223372036854775808 at org.apache.kafka.clients.producer.ProducerRecord.<init>(ProducerRecord.java:60) ~[kafka-clients-0.10.0.1.jar:na] at org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010.invokeInternal(FlinkKafkaProducer010.java:249) ~[flink-connector-kafka-0.10_2.10-1.2.0.jar:1.2.0] at org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010.processElement(FlinkKafkaProducer010.java:345) how do i put timestamp in my object before producing ? Thanks Archit
