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

kafka Create topic 报错

时间:2018-04-11 11:39:17      阅读:144      评论:0      收藏:0      [点我收藏+]

标签:kafka Create topic

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 报错

标签:kafka Create topic

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

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