Question

14
Replies
637
Views
JohanH55 Member since 2018 11 posts
Ernst & Young
Posted: 8 months ago
Last activity: 2 months 1 week ago
Solved

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:

...snip...

[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(KeeperException.java:119)
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 (kafka.network.SocketServer)

..snip...

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

Regards,

Johan

Pega Customer Decision Hub 8.1 Pega Customer Service 8.1 Pega Platform 8.1.1 Case Management Decision Management SR Created
Share this page LinkedIn