码迷,mamicode.com
首页 > 其他好文 > 详细

kafka 创建消费者报错

时间:2019-07-18 12:06:32      阅读:118      评论:0      收藏:0      [点我收藏+]

标签: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

  

kafka 创建消费者报错

标签:begin   boot   消费者   rom   问题   trap   tst   读取   版本   

原文地址:https://www.cnblogs.com/hanwen1014/p/11206359.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!