Hi,
I fail to start kafka broker when the corresponding zookeeper cluster is in
working but unhealthy state.
The zookeeper cluster is made of 3 nodes: zookeeper-0, zookeeper-1,
zookeeper-2.
I put all 3 zookeeper nodes into kafka's server.properties, specifically
for zookeeper.connect attribute as as:
zookeeper.connect=zookeeper-0.zookeeper.default.svc.cluster.local:2181,zookeeper-1.zookeeper.default.svc.cluster.local:2181,zookeeper-2.zookeeper.default.svc.cluster.local:2181
I intentionally terminate zookeeper-2 and let zookeeper cluster work with
only two nodes (zookeeper-0, zookeeper-1). Then I start start kafka and get
the following error message:
[2018-09-26 09:57:23,841] INFO Initiating client connection,
connectString=zookeeper-0.zookeeper.default.svc.cluster.local:2181,zookeeper-1.zookeeper.default.svc.cluster.local:2181,zookeeper-2.zookeeper.default.svc.cluster.local:2181
sessionTimeout=6000
watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@49ec71f8
(org.apache.zookeeper.ZooKeeper)
[2018-09-26 09:57:24,100] ERROR Fatal error during KafkaServer startup.
Prepare to shutdown (kafka.server.KafkaServer)
java.net.UnknownHostException:
zookeeper-2.zookeeper.default.svc.cluster.local: 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:445)
at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:380)
at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:86)
at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1538)
at
kafka.server.KafkaServer.kafka$server$KafkaServer$$createZkClient$1(KafkaServer.scala:345)
at kafka.server.KafkaServer.initZkClient(KafkaServer.scala:369)
at kafka.server.KafkaServer.startup(KafkaServer.scala:202)
at
kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38)
at kafka.Kafka$.main(Kafka.scala:92)
at kafka.Kafka.main(Kafka.scala)
[2018-09-26 09:57:24,104] INFO shutting down (kafka.server.KafkaServer)
[2018-09-26 09:57:24,107] WARN (kafka.utils.CoreUtils$)
java.lang.NullPointerException
at
kafka.server.KafkaServer$$anonfun$shutdown$5.apply$mcV$sp(KafkaServer.scala:569)
at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:85)
at kafka.server.KafkaServer.shutdown(KafkaServer.scala:569)
at kafka.server.KafkaServer.startup(KafkaServer.scala:326)
at
kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38)
at kafka.Kafka$.main(Kafka.scala:92)
at kafka.Kafka.main(Kafka.scala)
[2018-09-26 09:57:24,112] INFO shut down completed
(kafka.server.KafkaServer)
[2018-09-26 09:57:24,112] ERROR Exiting Kafka.
(kafka.server.KafkaServerStartable)
[2018-09-26 09:57:24,115] INFO shutting down (kafka.server.KafkaServer)
I thought we can start a kafka as long as the zookeeper cluster is
working.regardless there is one zookeeper node (3 in total) fails to run?
This is a UTF-8 formatted mail
-----------------------------------------------
James C.-C.Yu
+886988713275
+8615618429976
