Nir*_*ran 5 apache-kafka kafka-consumer-api
我正在尝试使用命令行工具 - kafka-console-consumer.sh 在不同的组名下为同一主题运行多个使用者。当我设置 --group 选项时,它失败并显示错误“组不是可识别的选项”。这一直很好,直到我升级到最新的 kafka 版本(kafka_2.11-0.8.2.2)。
我想了个办法。组选项不再适用于控制台消费者。如果您需要指定组,则可以使用 --consumer.config 选项来完成。它将consumer.properties 文件的路径作为输入。它对我有用。
小智 5
您可以使用 group.id 没有这样的配置文件: bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic test --consumer-property group.id=1
| 归档时间: |
|
| 查看次数: |
4245 次 |
| 最近记录: |