java - 如何获取 Flink 中记录的 Kafka 时间戳？

Question

我有一个Flink使用FlinkKafkaConsumer.

我有兴趣Kafka使用record/offset. KeyedDeserializationSchema似乎主题、分区、偏移量和消息都可用。

如何获取时间戳？

Answer 1

您可以简单地使用ConsumerRecord.timestamp()- 自纪元开始以来的时间戳（以毫秒为单位）（1970 年 1 月 1 日午夜（UTC））。时间戳类型在 timestampType() 中指明。