Hi
This is jingbo,I am a database engineer work in sina(china), I meet some error
when I start the kafka cluster,can you help me ?
The error is:
2016-02-02 16:52:20,916] ERROR Error while electing or becoming leader on
broker 10798841 (kafka.server.ZookeeperLeaderElector)
org.I0Itec.zkclient.exception.ZkException:
org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth
for /controller
at
org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:68)
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:222)
at
kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:237)
at
kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:275)
at
kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:76)
at
kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:49)
at
kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:47)
at
kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:47)
at kafka.utils.Utils$.inLock(Utils.scala:535)
at
kafka.server.ZookeeperLeaderElector.startup(ZookeeperLeaderElector.scala:47)
at
kafka.controller.KafkaController$$anonfun$startup$1.apply$mcV$sp(KafkaController.scala:650)
at
kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:646)
at
kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:646)
at kafka.utils.Utils$.inLock(Utils.scala:535)
at kafka.controller.KafkaController.startup(KafkaController.scala:646)
at kafka.server.KafkaServer.startup(KafkaServer.scala:117)
at
kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:29)
at kafka.Kafka$.main(Kafka.scala:46)
at kafka.Kafka.main(Kafka.scala)
Caused by: org.apache.zookeeper.KeeperException$NoAuthException:
KeeperErrorCode = NoAuth for /controller
at
org.apache.zookeeper.KeeperException.create(KeeperException.java:113)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:783)
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)
... 20 more
BTW:I had add acl on zookeeper which kafka rely on,Our kafka version is 0.8.2.2
_______________________________________________________________
JingBo Zhao<http://weibo.com/zbdba> �C 赵景波
[email protected]<mailto:[email protected]>
研发中心 - 平台架构部 - 数据库平台 - DBA
（手机）18610917066
Add.: 北京市海淀区北四环西路58号理想国际大厦17层
_______________________________________________________________
