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

Reply via email to