具体报错:[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)

在这里插入图片描述
使用的指令:
之后输入数据回车报错

./bin/kafka-console-producer.sh  --broker-list localhost:9092 --topic clicks

看了下相关配置文件

[root@master kafka]# cat config/server.properties | grep 9092
#     listeners = PLAINTEXT://your.host.name:9092
#listeners=PLAINTEXT://:9092
listeners=PLAINTEXT://master:9092
#advertised.listeners=PLAINTEXT://your.host.name:9092
[root@master kafka]# pwd
/export/server/kafka
[root@master kafka]#

从上述结果来看,是报错和配置里面的地址有关系,只需要改用配置里的hostname启动就好了

./bin/kafka-console-producer.sh  --broker-list master:9092 --topic clicks
Logo

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

更多推荐