kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nalin DeZoysa <ndezo...@tagged.com>
Subject Exception causing Kafka to crash
Date Thu, 06 Oct 2011 21:21:15 GMT
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)

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message