最近在使用plume log做日志系统时,发现如果使用kafka做消息队列时,会出现以下错误:

2020-07-21 14:15:29.571 WARN 13200 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-1] Error connecting to node DESKTOP-HOS9DR7:9092 (id: 1 rack: null)
java.net.UnknownHostException: DESKTOP-HOS9DR7
at java.net.InetAddress.getAllByName0(InetAddress.java:1281)
at java.net.InetAddress.getAllByName(InetAddress.java:1193)
at java.net.InetAddress.getAllByName(InetAddress.java:1127)
at org.apache.kafka.clients.ClientUtils.resolve(ClientUtils.java:104)
at org.apache.kafka.clients.ClusterConnectionStatesNodeConnectionState.currentAddress(ClusterConnectionStates.java:403)atorg.apache.kafka.clients.ClusterConnectionStatesNodeConnectionState.access$200(ClusterConnectionStates.java:363)
at org.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:151)
at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:943)
at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:288)
at org.apache.kafka.clients.producer.internals.Sender.sendProducerData(Sender.java:361)
at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:334)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244)
at java.lang.Thread.run(Thread.java:748)
复制代码

原因是kafka的配置问题:

原来的配置是:

listeners=PLAINTEXT://:9092
复制代码

应该的配置是:

listeners=PLAINTEXT://10.80.122.224:9092
复制代码

在一开始思考时,认为是和zookeeper设置有关,认为是和连接到本地的zookeeper有关,但其实是kafka设置存在问题,plume log应该没有走zookeeper去发现其他kafka服务

2020-07-21 14:15:27.390 INFO 13200 --- [localhost:2181)] org.apache.zookeeper.ClientCnxn : Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error)
复制代码
分类:
后端
  •