(DEPRECATED) Apache Flink Mailing List archive.
Search
everywhere
only in this topic
Advanced Search
How to get kafka record's timestamp in job
Classic
List
Threaded
♦
♦
Locked
1 message
刘建刚
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
How to get kafka record's timestamp in job
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.
Free forum by Nabble
Edit this page