是否从 kafka-console-consumer 工具中弃用了 --group 选项？如果是这样，我如何使用 kafka-console-consumer 设置消费者组。答案

【问题标题】：Is the --group option deprecated from kafka-console-consumer tool? if so, how can I set the consumer group using kafka-console-consumer.是否从 kafka-console-consumer 工具中弃用了 --group 选项？如果是这样，我如何使用 kafka-console-consumer 设置消费者组。
【发布时间】：2016-03-15 07:15:35
【问题描述】：

我正在尝试使用命令行工具 kafka-console-consumer.sh 在不同组名下为同一主题运行多个消费者。当我设置 --group 选项时，它会因错误“组不是可识别的选项”而失败。在我升级到最新的 kafka 版本（kafka_2.11-0.8.2.2）之前，这一切正常。

【问题讨论】：

你是从哪个版本升级的？

标签： apache-kafka kafka-consumer-api

【解决方案1】：

我想出了一个办法。控制台消费者不再可以使用组选项。如果您需要指定组，则可以使用 --consumer.config 选项来完成。它将 consumer.properties 文件的路径作为输入。它对我有用。

【讨论】：

【解决方案2】：

您可以使用 group.id 没有这样的配置文件： bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic test --consumer-property group.id=1

【讨论】：

【解决方案3】：

--group 在新 API 中不适用于 bin/kafka-console-consumer.sh。

默认情况下，所有消费者都使用config/consumer.properties，其中group.id=test-consumer-group。在任何地方创建一个属性文件，并输入group.id=<your-group-name>。

当您运行控制台消费者时，只需添加一个新参数为--consumer.config <your-newly-created-property-file>

$KAFKA_HOME/bin/kafka-console-consumer.sh --topic <topic-name> --zookeeper <zk-server>:<zk-port> --consumer.config <new-property-file>

【讨论】：

【解决方案4】：

组选项在 2.0.0 版中适用于我。

【讨论】：