Close popover
Johan Hoogenboezem (JohanH55)
Ernst & Young

Ernst & Young
JohanH55 Member since 2018 11 posts
Ernst & Young
Posted: November 26, 2019
Last activity: May 21, 2020

Stream node remain in "JOINING_FAILED" status

Hi All

We have a cluster in Production with one node on the Stream tab of the "Decisioning: Services" landing page remaining in JOINING_FAILED status (see attached screen shot). We traced it to this snippet in the Kafka server.log file:


[2019-11-25 11:13:23,513] INFO Creating /brokers/ids/6 (is it secure? false) (kafka.zk.KafkaZkClient)
[2019-11-25 11:13:23,541] ERROR Error while creating ephemeral at /brokers/ids/6, node already exists and owner '31139484958261249' does not match current session '31140168996945922' (kafka.zk.KafkaZkClient$CheckedEphemeral)
[2019-11-25 11:13:23,541] INFO Result of znode creation at /brokers/ids/6 is: NODEEXISTS (kafka.zk.KafkaZkClient)
[2019-11-25 11:13:23,550] ERROR [KafkaServer id=6] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists
at org.apache.zookeeper.KeeperException.create(
at kafka.zk.KafkaZkClient.checkedEphemeralCreate(KafkaZkClient.scala:1476)
at kafka.zk.KafkaZkClient.registerBrokerInZk(KafkaZkClient.scala:84)
at kafka.server.KafkaServer.startup(KafkaServer.scala:254)
at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38)
at kafka.Kafka$.main(Kafka.scala:75)
at kafka.Kafka.main(Kafka.scala)
[2019-11-25 11:13:23,553] INFO [KafkaServer id=6] shutting down (kafka.server.KafkaServer)
[2019-11-25 11:13:23,555] INFO [SocketServer brokerId=6] Stopping socket server request processors (


Does anyone have an idea of what the problem is here? We know next to nothing about Kafka.



Pega Customer Decision Hub 8.1 Pega Customer Service 8.1 Pega Platform 8.1.1 Case Management Decision Management Support Case Created