卡夫卡無法解決Zookeper的DNS名稱

我有一個卡夫卡0.10.1.0集羣（2個節點）和動物園管理員3.4.6（3個節點）卡夫卡無法解決Zookeper的DNS名稱

羣集位於Kubernetes以下this tutorial主持。從卡夫卡的server.properties

相關條目：

listeners=PLAINTEXT://0.0.0.0:9092 
advertised.listeners=PLAINTEXT://kafka.internal.<companyname>.com:9092 
zookeeper.connect=zookeeper-1:2181,zookeeper-2:2181,zookeeper-3:2181

在服務器啓動時，各券商卡夫卡用下面很快失敗。對我來說，它看起來像無法解析DNS名稱zookeeper-1。我也嘗試從zookeeper.connect中刪除端口，雖然我讀的是the relevant code，但我不認爲這會有所作爲。

當然，我確認zookeeper-1可以從集羣內解決。集羣內的其他容器可以解析名稱。

我也嘗試了一系列其他別名，包括服務的DNS名稱和Zookeeper的負載平衡器，所有這些都是我獨立確認的工作。在每種情況下，僅卡夫卡報告Name or service not known。

[2016-11-22 19:55:45,506] INFO Initiating client connection, connectString=zookeeper-1:2181,zookeeper-2:2181,zookeeper-3:2181 sessionTimeout=6000 [email protected] (org.apache.zookeeper.ZooKeeper) 
[2016-11-22 19:56:05,571] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) 
[2016-11-22 19:56:05,572] FATAL Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) 
org.I0Itec.zkclient.exception.ZkException: Unable to connect to zookeeper-1:2181,zookeeper-2:2181,zookeeper-3:2181 
    at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:71) 
    at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1227) 
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:156) 
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:130) 
    at kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:76) 
    at kafka.utils.ZkUtils$.apply(ZkUtils.scala:58) 
    at kafka.server.KafkaServer.initZk(KafkaServer.scala:327) 
    at kafka.server.KafkaServer.startup(KafkaServer.scala:200) 
    at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:39) 
    at kafka.Kafka$.main(Kafka.scala:67) 
    at kafka.Kafka.main(Kafka.scala) 
Caused by: java.net.UnknownHostException: zookeeper-1: Name or service not known 
    at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method) 
    at java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:928) 
    at java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1323) 
    at java.net.InetAddress.getAllByName0(InetAddress.java:1276) 
    at java.net.InetAddress.getAllByName(InetAddress.java:1192) 
    at java.net.InetAddress.getAllByName(InetAddress.java:1126) 
    at org.apache.zookeeper.client.StaticHostProvider.<init>(StaticHostProvider.java:61) 
    at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:446) 
    at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:380) 
    at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:69) 
    ... 10 more 
[2016-11-22 19:56:05,575] INFO shutting down (kafka.server.KafkaServer) 
[2016-11-22 19:56:05,616] INFO shut down completed (kafka.server.KafkaServer)

其他信息相關的卡夫卡形象：它是基於關閉wurstmeister/kafka-docker但更新到openjdk:8-jre繼承。

來源

2016-11-22 Sam Myers

您是否嘗試過使用這些PetSets的完全限定域名？解析方法通常不適用於短名稱。 – MrE

你可以ping'zookeeper-1'嗎？主機名是否可以解決？ – bsd

事實證明，這是Kubernetes本身的一個問題。

經過與v1.4.6無關的升級並沒有其他更改後，名稱能夠正常解析。

來源

2016-11-28 19:35:52

卡夫卡無法解決Zookeper的DNS名稱

回答

相關問題