kafka-consumer-group опишите результаты, в потребительской группе не существует

Question

Я пытался запустить следующие сценарии программно в java, и по большей части они работают, но для некоторых эта ошибка продолжает появляться: «группа потребителей xyz не существует».Может кто-нибудь объяснить, почему эта ошибка возникает, особенно если группа потребителей появляется в скрипте --list.

 kafka/bin/kafka-consumer-groups.sh --zookeeper 
 192.xxx.x.xxx:2181 --describe -group TEST_CONSUMER

Возвращает ошибку:

Error: The consumer group 'TEST_CONSUMER' does not exist.

Но этот скрипт выведет списокгруппа потребителей как активная:

kafka/bin/kafka-consumer-groups.sh --zookeeper 192.xxx.x.xxx:2181 --list

Так почему же, если она указана в списке, вернуть ошибку, сообщив, что ее не существует?Также относится к группам потребителей - я запускаю этот скрипт для получения информации о задержке, как мне сказали, что это невозможно получить с помощью метрик jmx в kafka 1.0, если я не подключусь к каждому серверу потребителей или чему-то еще.Может ли кто-нибудь это проверить?

Спасибо

Answer 1

Сначала перечислите группы в кластере:

bin/kafka-consumer-groups.sh --bootstrap-server $IP_Address:9092 --list

затем опишите нужную группу:

bin/kafka-consumer-groups.sh --bootstrap-server $IP_Address:9092 --group $GROUPID --describe

В случае, если это не работает, я полагаю, вы описываете группу, которая находится в ZK (старый пользователь akka), это старый kafkaconsumer, который хранится в ZK. Какая версия вашего потребительского клиента kafka?

Answer 2

Использовать bootstrap-server, а не zookeeper здесь

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group

Примечание. При этом будет отображаться только информация о потребителях, использующих API потребителей Java (не-ZooKeeper-на основе потребителей).