В Kafka невозможно создать нового потребителя, используя kafka-consumer-groups.sh

Question

Я установил для kafka автономный узел (HDF ver 3.1.1, Kafka ver 1.0.0)

Чтобы загрузить данные из кафки, она создает группу потребителей, которая использует kafka-consumer-groups.sh

Команда такая

kafka-consumer-groups.sh --bootstrap-server ip-xxx-xxx-xxx-xxx:6667 (--new-consumer) --describe --group logstash

Но я встречаю сообщение об ошибке

Note: This will not show information about old Zookeeper-based consumers.
Error: Executing consumer group command failed due to The consumer group command timed out while waiting for group to initialize:

Как я могу решить эту проблему?

Answer 1

Следующее создаст потребителя под group-1 (и создайте группу, если она еще не существует):

kafka-console-consumer --bootstrap-server localhost:9092 --topic topic --from-beginning--consumer-property group.id=group-1

Также обратитесь к следующему вопросу:
как установить имя группы при использовании сообщений в kafka с помощью командной строки