我在我的k8集群上安装了bitnami kafka。但我一直在kafka-o日志中看到错误java.net.UnknownHostException: kafka-0.kafka-headless.kafka.svc.cluster.local。
我登录到pod (kafka-o)并运行nslookup查找kafka-0.kafka-headless.kafka.svc.cluster.local,但IP得到了解决,没有出现任何问题
root@kafka-0:/# nslookup kafka-0.kafka-headless.kafka.svc.cluster.local
Server: 10.43.0.10
Address: 10.43.0.10#53
Name: kafka-0.kafka-headless.kafka.svc.mosip02.local
Address: 10.42.4.123
kafka-0 pod的netstat日志
root@kafka-0:/# netstat -lntp
Active Internet connections (only servers)
Proto Recv-Q Send-Q Local Address Foreign Address State PID/Program name
tcp 0 0 0.0.0.0:35267 0.0.0.0:* LISTEN -
tcp 0 0 0.0.0.0:9092 0.0.0.0:* LISTEN -
tcp 0 0 0.0.0.0:9093 0.0.0.0:* LISTEN -
kubectl -n kafka日志中的错误堆栈kafka-0
[2021-07-26 07:59:29,350] WARN [Controller id=0, targetBrokerId=0] Error connecting to node kafka-0.kafka-headless.kafka.svc.cluster.local:9093 (id: 0 rack: null) (org.apache.kafka.clients.NetworkClient)
java.net.UnknownHostException: kafka-0.kafka-headless.kafka.svc.cluster.local
at java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)
at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1509)
at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1368)
at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1302)
at org.apache.kafka.clients.DefaultHostResolver.resolve(DefaultHostResolver.java:27)
at org.apache.kafka.clients.ClientUtils.resolve(ClientUtils.java:111)
at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.currentAddress(ClusterConnectionStates.java:512)
at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.access$200(ClusterConnectionStates.java:466)
at org.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:172)
at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:985)
at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:311)
at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:65)
at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:292)
at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:246)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96)
发布于 2021-07-27 15:59:12
尝试编辑clusterDomain
参数,在部署图表时将其设置为mosip02.local
而不是cluster.local
https://stackoverflow.com/questions/68526530
复制相似问题