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