У меня есть KAFKA 0.10.1.0 кластера (2 узлов) и (3.4.6 зоопарка 3 узлов)Кафка не может разрешить DNS-имя Zookeper в
кластеры размещаются на 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.
Вы пробовали использовать полное квалифицированное доменное имя для этих наборов PetSet? Часто методы решения проблем не работают с коротким именем. – MrE
Можете ли вы ping 'zookeeper-1'? Можно ли разрешить имя хоста? – bsd