search

daangn-daangn / daangn-server

๐Ÿฅ•๋‹น๊ทผ ์„œ๋ฒ„ ๋ฆฌํฌ์ง€ํ† ๋ฆฌ๐Ÿฅ•
4 stars 2 forks source link

Kafka shutting down on the initial run with the error 'node already exists' #70

Closed cotchan closed 2 years ago

cotchan commented 2 years ago 
kafka          | [2022-06-22 18:42:58,923] ERROR Error while creating ephemeral at /brokers/ids/1, node already exists and owner '72057601558577153' does not match current session '72057638284230657' (kafka.zk.KafkaZkClient$CheckedEphemeral)
kafka          | [2022-06-22 18:42:58,929] ERROR [KafkaServer id=1] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka          | org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists
kafka          |    at org.apache.zookeeper.KeeperException.create(KeeperException.java:126)
kafka          |    at kafka.zk.KafkaZkClient$CheckedEphemeral.getAfterNodeExists(KafkaZkClient.scala:1904)
kafka          |    at kafka.zk.KafkaZkClient$CheckedEphemeral.create(KafkaZkClient.scala:1842)
kafka          |    at kafka.zk.KafkaZkClient.checkedEphemeralCreate(KafkaZkClient.scala:1809)
kafka          |    at kafka.zk.KafkaZkClient.registerBroker(KafkaZkClient.scala:96)
kafka          |    at kafka.server.KafkaServer.startup(KafkaServer.scala:324)
kafka          |    at kafka.Kafka$.main(Kafka.scala:109)
kafka          |    at kafka.Kafka.main(Kafka.scala)

์—๋Ÿฌ๋ฉ”์‹œ์ง€ ์˜๋ฏธ