Странный вывод из kafka-consumer-groups.sh

У меня есть группа потребителей под названием myconsumergroup, которая появляется при запуске:

bin/kafka-consumer-groups.sh --zookeeper zookeeper:2181 --list
> myconsumergroup

Я очень уверен, что совершил смещение. Я ожидаю, что это смещение может быть получено с помощью этой команды:

bin/kafka-consumer-groups.sh --zookeeper zookeeper:2181 --describe --group myconsumergroup     

Но вместо этого я получаю этот запутанный вывод:

No topic available for consumer group provided
GROUP                          TOPIC                          PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             OWNER

Кто-нибудь может объяснить, почему я не получаю текущее смещение для myconsumergroup?

NB. Для получения дополнительной информации я создал своего потребителя в своем приложении NodeJS следующим образом:

new Consumer(
        client,
        [
          {topic}
        ],
        {
          groupId:'myconsumergroup'
        }
      )

И клиент Kafka создается так:

const client = new kafkanode.Client('localhost:2181', 'myservice');

0 ответов

Другие вопросы по тегам