配置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
应该就可以了。
做个小笔记。
原文地址:http://blog.51cto.com/xpu2001/2096824