Login  Register

How to get kafka record's timestamp in job

Posted by liujiangang on Dec 31, 2019; 2:37pm
URL: http://apache-flink.370.s1.nabble.com/How-to-get-kafka-record-s-timestamp-in-job-tp1361.html

      In kafka010, ConsumerRecord has a field named timestamp. It is
encapsulated
in Kafka010Fetcher. How can I get the timestamp when I write a flink job?
Thank you very much.