标签:begin boot 消费者 rom 问题 trap tst 读取 版本
kafka-console-consumer.sh --zookeeper master:2181,slave1:2181,slave2:2181 --topic test --from-beginning # zookeeper is not a recognized option
在创建消费者的时候出现 zookeeper is not a recognized option,经过在浏览器搜索发现是版本问题,消费者读取信息配置不在是 zookeeper 的节点信息,而直接改成 kafka 本身的信息,将上面的语句改成下面即可。
kafka-console-consumer.sh --zookeeper master:2181,slave1:2181,slave2:2181 --topic test --from-beginning # 改成下面这样 kafka-console-consumer.sh --bootstrap-server master:9092 --topic baduo --from-beginning # --zookeeper master:2181,slave1:2181,slave2:2181 # 变成了 # --bootstrap-server master:9092
标签:begin boot 消费者 rom 问题 trap tst 读取 版本
原文地址:https://www.cnblogs.com/hanwen1014/p/11206359.html