我知道可以获取kafka的最新偏移量,但是是否可以通过kafka控制台脚本获取kafka主题的最后更改的时间戳?

我看到了这个问题,但没有真正答案。

最佳答案

您无法从脚本中直接获取时间戳。相反,您可以使用console-consumer脚本查看时间戳。它显示消息的CreateTime
也如@Sreekiran所述,使用属性“ print.timestamp”,如下所示:

ncsv@ubuntu:/data/softwares/kafka_2.11-2.0.0$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testJsonTopic1 --property print.timestamp=true --from-beginning
CreateTime:1544445041225        {"id": "9","name": "wis"}
CreateTime:1544518616282        {"id": "19","name": "wes"}
CreateTime:1544520723808        {"id": "1","name": "test1"}
CreateTime:1544446690508        {"id": "9","name": "wes"}
CreateTime:1544445375123        {"id": "9","name": "wes"}
CreateTime:1544520388080        {"id": "20","name": "test1"}


它将显示将事件写入集群的时间。

10-03 00:28