потребитель kafka не отчитывается перед группой потребителей - PullRequest
0 голосов
/ 12 ноября 2018

мы настроили кластер Kafka с одним узлом и запустили приложение потребителей на другом сервере (работает около 10 потребителей). Когда я пытаюсь получить информацию о потребителе из командной строки kafka, я вижу, что немногие потребители не отчитываются перед потребителем, поскольку я получаю только заголовки выходных данных команды, а не фактические данные о потребителе kafka.

user@kafkaserver:/home/kafka/kafka$ bin/kafka-consumer-groups.sh  --bootstrap-server <brokerip>:9092 --describe --group <group_name>
Note: This will only show information about consumers that use the Java consumer API (non-ZooKeeper-based consumers).


TOPIC                          PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG        CONSUMER-ID                                       HOST                           CLIENT-ID

Сервер, на котором работают потребители, может подключаться к серверу брокера через порт 9092, а также к zookeeper. Может ли это быть проблемой для потребителя?

...