Странный вывод из 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');