Hi,
I'm seeing this error occasionally, that causes Kafka to crash. Does anyone
know what the cause of this error is and how can I prevent against this
happening?
Thanks,
Nalin
[2011-10-03 15:33:22,193] INFO Awaiting connections on port 9092
(kafka.network.Acceptor)
[2011-10-03 15:33:22,193] INFO Registering broker /brokers/ids/0
(kafka.server.KafkaZooKeeper)
[2011-10-03 15:33:22,229] INFO conflict in /brokers/ids/0 data:
10.98.20.109-1317681202194:10.98.20.109:9092 stored data:
10.98.20.109-1317268078266:10.98.20.109:9092 (kafka.utils.ZkUtils$)
[2011-10-03 15:33:22,230] FATAL
org.I0Itec.zkclient.exception.ZkNodeExistsException:
org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode =
NodeExists for /brokers/ids/0 (kafka.server.KafkaServer)
[2011-10-03 15:33:22,231] FATAL
org.I0Itec.zkclient.exception.ZkNodeExistsException:
org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode =
NodeExists for /brokers/ids/0
at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:55)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685)
at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
at org.I0Itec.zkclient.ZkClient.createEphemeral(ZkClient.java:328)
at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:55)
at
kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:71)
at
kafka.server.KafkaZooKeeper.registerBrokerInZk(KafkaZooKeeper.scala:54)
at kafka.log.LogManager.startup(LogManager.scala:122)
at kafka.server.KafkaServer.startup(KafkaServer.scala:77)
at
kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:40)
at kafka.Kafka$.main(Kafka.scala:56)
at kafka.Kafka.main(Kafka.scala)
Caused by: org.apache.zookeeper.KeeperException$NodeExistsException:
KeeperErrorCode = NodeExists for /brokers/ids/0
at org.apache.zookeeper.KeeperException.create(KeeperException.java:110)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:42)
at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:637)
at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
... 10 more
(kafka.server.KafkaServer)
[2011-10-03 15:33:22,231] INFO Shutting down... (kafka.server.KafkaServer)
[2011-10-03 15:33:22,232] INFO shutdown scheduler kafka-logcleaner-
(kafka.utils.KafkaScheduler)
[2011-10-03 15:33:22,239] INFO shutdown scheduler kafka-logflusher-
(kafka.utils.KafkaScheduler)
[2011-10-03 15:33:22,481] INFO zkActor stopped (kafka.log.LogManager)
[2011-10-03 15:33:22,482] INFO Closing zookeeper client...
(kafka.server.KafkaZooKeeper)
[2011-10-03 15:33:22,482] INFO Terminate ZkClient event thread.
(org.I0Itec.zkclient.ZkEventThread)
[2011-10-03 15:33:22,486] INFO Session: 0x132b34a9a89006a closed
(org.apache.zookeeper.ZooKeeper)
[2011-10-03 15:33:22,486] INFO shut down completed
(kafka.server.KafkaServer)
