kafka 创建消费者报错

Posted 2022-04-22 hanwen1014

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