在 Kafka 中，无法使用 kafka-consumer-groups.sh 创建新的消费者答案

【问题标题】：In Kafka, cannot create new consumer using kafka-consumer-groups.sh在 Kafka 中，无法使用 kafka-consumer-groups.sh 创建新的消费者
【发布时间】：2018-05-14 12:08:38
【问题描述】：

我设置了一个 Kafka 独立节点（HDF 版本 3.1.1，Kafka 版本 1.0.0）

要从 kafka 加载数据，可以使用 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:

我该如何解决这个问题？

【问题讨论】：

kafka-consumer-groups.sh 不创建消费者组...您使用 group.id 创建客户端...
@JustinPihony 谢谢。我使用这个链接解决了这个问题：stackoverflow.com/questions/38549867/…

标签： apache-kafka hdf

【解决方案1】：

以下将在group-1 下创建一个消费者（如果该组不存在，则创建该组）：

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

另请参考以下问题：
how to set group name when consuming messages in kafka using command line

【讨论】：