Kafka的java客户端连接出现Connection refused: no further information

编程入门 行业动态 更新时间:2024-10-26 18:20:22

在正常配置zookeeper和kafka后,编写测试代码发现报错了:

java.net.ConnectException: Connection refused: no further information
	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
	at org.apache.kafka.common.network.PlaintextTransportLayer.finishConnect(PlaintextTransportLayer.java:50)
	at org.apache.kafka.common.network.KafkaChannel.finishConnect(KafkaChannel.java:216)
	at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:531)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:483)
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:539)
	at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:335)
	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244)
	at java.lang.Thread.run(Thread.java:748)
20:12:34.033 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Node -1 disconnected.

在网上搜到相关教程,说是修改 /config/server.properties 文件,添加下面这条语句即可

host.name=192.168.137.199

一番操作,报错依旧,终于定位了问题,同样是修改 /config/server.properties ,但是问题点在于

listeners=PLAINTEXT://localhost:9092

将localhost修改为kafka当前的操作系统的地址即可(如果当前java代码所在的操作系统与kafka一致则不需要)。

更多推荐

Kafka的java客户端连接出现Connection refused: no further information

本文发布于:2023-06-14 00:53:00,感谢您对本站的认可!
本文链接:https://www.elefans.com/category/jswz/34/1419901.html
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。
本文标签:客户端   java   Kafka   information   refused

发布评论

评论列表 (有 0 条评论)
草根站长

>www.elefans.com

编程频道|电子爱好者 - 技术资讯及电子产品介绍!