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

Question

我有一个使用FlinkKafkaConsumer 的Flink 应用程序。

我有兴趣使用KeyedDeserializationSchema 检索给定record/offset 的Kafka 时间戳。好像topic、partition、offset、message都可以了。

如何获取时间戳？

Answer 1

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