生产者如何获得Kafka max偏移量

Question

如何使用命令行获取一个主题的最大偏移量.我的意思是不属于任何消费者的最大偏移量,它是生产者的最大偏移量.

Answer 1

Kafka提供系统工具GetOffsetShell以获取主题的每个分区的最新偏移量.
例如,考虑具有2个分区的主题"MyTestTopic".然后命令应该是

bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --partitions 1,0 --topic MyTestTopic --time -1