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 版本。
我正在尝试 运行 使用命令行工具 - 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 版本。