我是kafka的新手，我有一个代理节点，在其中我创建了一个主题，其中有1个副本和1500个分区。我在这个特定的主题上收集了大量的数据。现在有没有办法，我可以计算出在哪个分区中有多少数据？在向kafka发送数据时，我没有发送任何密钥，因此我知道它将以循环方式选择分区，但我想看看在这1500个分区中每个分区中有多少数据。有没有办法解决这个问题？
mtb9vblg1#
运行命令：bin/kafka-run-class.sh kafka.tools.getoffsetshell—代理列表host:port --topic 你的主题--时间-1结果列出了每个分区的偏移量，可以认为是生成的消息编号。
1条答案
按热度按时间mtb9vblg1#
运行命令：
bin/kafka-run-class.sh kafka.tools.getoffsetshell—代理列表host:port --topic 你的主题--时间-1
结果列出了每个分区的偏移量，可以认为是生成的消息编号。