Question

14
Replies
1263
Views
Johan Hoogenboezem (JohanH55)
Ernst & Young
Senior Manager
Ernst & Young
ZA
JohanH55 Member since 2018 11 posts
Ernst & Young
Posted: November 26, 2019
Last activity: May 21, 2020
Posted: 26 Nov 2019 3:53 EST
Last activity: 21 May 2020 18:50 EDT
Closed
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...

Show More

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

Show Less
Pega Customer Decision Hub 8.1 Pega Customer Service 8.1 Pega Platform 8.1.1 Case Management Decision Management Support Case Created
Moderation Team has archived post, This thread is closed to future replies. Content and links will no longer be updated. If you have the same/similar Question, please write a new Question.