如何检查一个特定的消费群体是否完全消费了一个主题？这相当于在标准排队系统中检查队列是否为空。这一点并不明显，因为每个使用者只看到它所给出的分区，因此它不知道组中的其他使用者是否使用了他们的部分。我想这应该由我来做 AdminUtils 或者 ZkUtils 但我似乎找不到正确的方法。
AdminUtils
ZkUtils
1qczuiv01#
请使用 kafka-consumer-groups.sh 检查耗电元件偏移。（kafka-consumer-offset-checker.sh具有类似的功能，但在0.9.0.0中已被弃用。）bin/kafka-consumer-groups.sh—引导服务器:9092--group -group-id --描述——新消费者组主题分区当前偏移日志结束偏移延迟所有者consumer.test.0529.095217 secured\u主题0 586 3333 2747 consumer-1/10.139.0.4 consumer.test.0529.095217 secured\u主题3334 3334 0 consumer-1/10.139.0.4 consumer.test.0529.095217 secured\u主题2 0 3333 3333 consumer-1/10.139.0.4
kafka-consumer-groups.sh
1条答案
按热度按时间1qczuiv01#
请使用
kafka-consumer-groups.sh检查耗电元件偏移。（kafka-consumer-offset-checker.sh具有类似的功能，但在0.9.0.0中已被弃用。）
bin/kafka-consumer-groups.sh—引导服务器:9092--group -group-id --描述——新消费者
组主题分区当前偏移日志结束偏移延迟所有者consumer.test.0529.095217 secured\u主题0 586 3333 2747 consumer-1/10.139.0.4 consumer.test.0529.095217 secured\u主题3334 3334 0 consumer-1/10.139.0.4 consumer.test.0529.095217 secured\u主题2 0 3333 3333 consumer-1/10.139.0.4