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

Question

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

我看到了这个问题Kafka: How to get last modified time for a topic 即最后一条消息添加到该主题的任何分区，但没有真正回答我的问题。

Answer 1

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

Answer 2

您无法直接从脚本中获取时间戳。相反，您可以使用控制台消费者脚本查看时间戳。它显示了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"}

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