Как проверить, была ли тема потреблена потребителем в Kafka

Question

Как проверить, полностью ли потребляемая вами конкретная группа потребителей?
Это эквивалент проверки того, является ли очередь пустой в стандартной системе очередей.
Это не очевидно, так как каждый потребитель видит только разделы, которые он отдает, поэтому он не осведомлен о том, что другие потребители в его группе потребляли свою часть.
Я думаю, что это должно быть сделано как-то AdminUtils или ZkUtils, но я не могу найти правильный путь.

Answer 1

Пожалуйста, используйте kafka-consumer-groups.sh для проверки потребительской компенсации.
(The kafka-consumer-offset-checker.sh имеет аналогичные функциональные возможности, но является устаревшим в 0.9.0.0.)

бен/kafka-consumer-groups.sh ххх --bootstrap-сервера: 9092- -группа ххх-группы ID --describe --new-потребитель
гРУППА ТЕМА РАЗДЕЛА ТОК-OFFSET ЛОГ-END-OFFSET LAG ПРЕДПРИНИМАТЕЛЬ consumer.test.0529.095217 secured_topic 0 586 3333 2747 потребитель-1_/10.139.0.4 consumer.test.0529.095217 secure_topic 3334 3334 0 потребитель-1_/10.139.0.4 потребитель.test.0529.095217 protected_topic 2 0 3333 3333 потребитель-1_/10.139.0.4