如何检查Kafka中的消费者是否使用了某个主题

Question

如何检查特定的消费者群体是否完全消耗了某个主题？
这相当于检查标准排队系统中队列是否为空.
这并不明显,因为每个消费者只看到它给出的分区,因此它不知道其组中的其他消费者是否消耗了他们的部分.
我想这应该通过某种方式来完成AdminUtils或者ZkUtils,但我似乎无法找到正确的方式.

Answer 1

请用于kafka-consumer-groups.sh检查消费者抵消.
(kafka-consumer-offset-checker.sh具有类似的功能,但已在0.9.0.0中弃用.)

bin/kafka-consumer-groups.sh --bootstrap-server xxx:9092 - group xxx-group-id --describe --new-consumer
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG OWNER consumer.test. 0529.095217 secured_topic 0 586 3333 2747 consumer-1_/10.139.0.4 consumer.test.0529.095217 secured_topic 3334 3334 0 consumer-1_/10.139.0.4 consumer.test.0529.095217 secured_topic 2 0 3333 3333 consumer-1_/10.139.0.4