首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >Bitnami Kafka for Kibernetes - java.net.UnknownHostException: kafka-0.kafka-headless.kafka.svc.cluster.local

Bitnami Kafka for Kibernetes - java.net.UnknownHostException: kafka-0.kafka-headless.kafka.svc.cluster.local
EN

Stack Overflow用户
提问于 2021-07-26 16:16:51
回答 1查看 327关注 0票数 0

我在我的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得到了解决,没有出现任何问题

代码语言:javascript
运行
复制
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日志

代码语言:javascript
运行
复制
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

代码语言:javascript
运行
复制
[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)
EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2021-07-27 15:59:12

尝试编辑clusterDomain参数,在部署图表时将其设置为mosip02.local而不是cluster.local

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/68526530

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档