如何使用命令行获取一个主题的最大偏移量。我指的是不属于任何消费者的最大偏移量，它是生产者的最大偏移量。
xxls0lw81#
kafka提供了系统工具getoffsetshell来获取每个主题分区的最新偏移量。例如，考虑一个带有2个分区的主题“mytesttopic”。那么命令应该是 bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --partitions 1,0 --topic MyTestTopic --time -1
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --partitions 1,0 --topic MyTestTopic --time -1
1条答案
按热度按时间xxls0lw81#
kafka提供了系统工具getoffsetshell来获取每个主题分区的最新偏移量。
例如，考虑一个带有2个分区的主题“mytesttopic”。那么命令应该是
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --partitions 1,0 --topic MyTestTopic --time -1