apache-kafka - 如何使用 kafka 命令行获取给定 kafka 主题的所有分区的日志结束偏移量？

Question

当我描述一个 kafka 主题时，它不会显示任何分区的日志结束偏移量，而是显示所有其他元数据，例如 ISR、Replicas、Leader。

如何查看给定主题的分区的日志结束偏移量？

跑了这个：./kafka-topics.sh --zookeeper zk-service:2181 --describe --topic "__consumer_offsets"

输出没有偏移列。

注意：只需要日志结束偏移量。

标签： apache-kafka

Answer 1

由于您只是在寻找主题的日志结束偏移量，因此您可以kafka-run-class与kafka.tools.GetOffsetShell该类一起使用。

假设您的主题是__consumer_offsets，您将通过运行获得结束偏移：

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --time -1 --topic __consumer_offsets

将 更改--broker-list localhost:9092为您想要的 Kafka 地址。这将列出主题中每个分区的所有日志结束偏移量。