刘建刚 Tue, 31 Dec 2019 06:38:10 -0800
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.