问题:

WARN [Producer clientId=console-producer] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

解决

必须与在配置文件里面的listeners保存一致,尽管你在里面设置的是当前虚拟机的ip,

我就是使用了自己虚拟机的ip,如何通过localhost:9092去访问也是不可以的

如下:

listeners=PLAINTEXT://192.168.156.131:9092
# 在命令使用时也必须使用192.168.156.131:9092作为连接的地址,如下
./kafka-console-producer.sh --broker-list 192.168.156.131:9092 --topic userlog
Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐