获取Kafka主题的最后修改日期

ndasle7k  于 2021-06-07  发布在  Kafka
关注(0)|答案(2)|浏览(348)

我知道可以获取Kafka的最新偏移量,但是可以通过Kafka控制台脚本获取Kafka主题最后一次更改的时间戳吗?
我看到这个问题Kafka:如何得到最后修改时间的主题,即最后一条消息添加到任何分区的主题,但没有真正的答案我的问题。

rdlzhqv9

rdlzhqv91#

将此添加到当前命令 --property print.timestamp=true 它将打印时间戳 CreateTime:1544706749268 .

mrfwxfqh

mrfwxfqh2#

你不能直接从脚本中得到时间戳。相反,您可以使用控制台使用者脚本查看时间戳。它显示了 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"}

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

相关问题