flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 刘建刚 <liujiangangp...@gmail.com>
Subject How to get kafka record's timestamp in job
Date Tue, 31 Dec 2019 14:37:17 GMT
      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.

Mime
View raw message