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.sh 在不同组名下针对同一主题的多个消费者。当我设置 --group 选项时,它失败并显示错误 'group is not a recognized option'。在我升级到最新的 kafka 版本 (kafka_2.11-0.8.2.2) 之前,它工作正常。

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

--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>

您可以在没有配置文件的情况下使用 group.id,如下所示: bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic test --consumer-属性 group.id=1

组选项适用于 2.0.0 版本。