мы настроили кластер 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. Может ли это быть проблемой для потребителя?