我知道可以获取Kafka的最新偏移量,但是可以通过Kafka控制台脚本获取Kafka主题最后一次更改的时间戳吗?我看到这个问题Kafka:如何得到最后修改时间的主题,即最后一条消息添加到任何分区的主题,但没有真正的答案我的问题。
rdlzhqv91#
将此添加到当前命令 --property print.timestamp=true 它将打印时间戳 CreateTime:1544706749268 .
--property print.timestamp=true
CreateTime:1544706749268
mrfwxfqh2#
你不能直接从脚本中得到时间戳。相反,您可以使用控制台使用者脚本查看时间戳。它显示了 CreateTime 对于@sreekiran提到的消息,也可以使用“print.timestamp”属性,如下所示:
CreateTime
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"}
它将显示事件写入集群的时间。
2条答案
按热度按时间rdlzhqv91#
将此添加到当前命令
--property print.timestamp=true
它将打印时间戳CreateTime:1544706749268
.mrfwxfqh2#
你不能直接从脚本中得到时间戳。相反,您可以使用控制台使用者脚本查看时间戳。它显示了
CreateTime
对于@sreekiran提到的消息,也可以使用“print.timestamp”属性,如下所示:它将显示事件写入集群的时间。