flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Archit Mittal <marchi...@gmail.com>
Subject Doubt Regarding producing to kafka using flink
Date Sun, 02 Apr 2017 10:38:00 GMT
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

Mime
View raw message