You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by 赵景波 <ji...@staff.sina.com.cn> on 2016/02/02 10:04:03 UTC

NoAuth for /controller

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 �Ծ���                 jingbo8@staff.sina.com.cn<ma...@staff.sina.com.cn>

�з����� - ƽ̨�ܹ��� - ���ݿ�ƽ̨ - DBA
���ֻ���18610917066
Add.: �����к��������Ļ���·58��������ʴ���17��
_______________________________________________________________