我收到了启发,扩写句子
你遇到的问题似乎是在使用Kafka的消费者时,遇到了broker-list不被识别的问题。这可能是由于你使用的Kafka版本和命令不匹配所导致的。
在旧版本的Kafka中,我们通常使用--zookeeper选项来指定Zookeeper的地址,然后通过Zookeeper来连接到Kafka broker。然而,在新版本的Kafka中,这个选项已经被废弃,取而代之的是--bootstrap-serverkafka命令选项。
所以,如果你正在使用新版本的Kafka,你应该将命令中的--zookeeper替换为--bootstrap-server,并指定你的broker地址。例如:
bash复制代码
./kafka-console-consumer.sh --bootstrap-server ip10:9092,ip11:9092,ip12:9092 --topic testTopic
如果你正在使用的是旧版本的Kafka,但是你的命令中没有--zookeeper选项,那么你可能需要检查你的Kafka安装是否正确,或者尝试更新你的Kafka版本。

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。