首页 > 其他 > 详细

kafka Create topic 报错

时间:2018-04-11 11:31:22      阅读:348      评论:0      收藏:0      [点我收藏+]
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic kk_log
报错如下:
WARN [Consumer clientId=consumer-1, groupId=console-consumer-507] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

配置server.confg时候设置的
advertised.listeners=PLAINTEXT://10.171.222.26:9092
此时需要用配置的IP而非localhost地址:

nohup bin/zookeeper-server-start.sh config/zookeeper.properties > /dev/null 2>&1 &
nohup bin/kafka-server-start.sh config/server.properties > /dev/null 2>&1 &
netstat -ntpl|egrep "(2181|9092)"
运行起来再试试
bin/kafka-console-consumer.sh --bootstrap-server 10.171.222.26:9092 --topic kk_log
应该就可以了。
做个小笔记。

kafka Create topic 报错

原文:http://blog.51cto.com/xpu2001/2096824

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!