我正在使用apachekafka进行消息传递。我已经用java实现了生产者和消费者。我们如何获得一个主题中的消息数？
yrefmtwq16#
它不是java，但可能有用
./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list <broker>: <port> --topic <topic-name> --time -1 --offsets 1 | awk -F ":" '{sum += $3} END {print sum}'
nzk0hqpo17#
实际上，我用它来测试我的poc。您要使用consumeroffsetchecker的项目。您可以使用bash脚本运行它，如下所示。
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic test --zookeeper localhost:2181 --group testgroup
结果如下：正如您在红色框中看到的，999是当前主题中的邮件数。更新：自0.10.0以来，ConsumerOffSecker已被弃用，您可能希望开始使用consumergroupcommand。
17条答案
按热度按时间yrefmtwq16#
它不是java，但可能有用
nzk0hqpo17#
实际上，我用它来测试我的poc。您要使用consumeroffsetchecker的项目。您可以使用bash脚本运行它，如下所示。
结果如下：
正如您在红色框中看到的，999是当前主题中的邮件数。
更新：自0.10.0以来，ConsumerOffSecker已被弃用，您可能希望开始使用consumergroupcommand。