Kafka doesn't have security enabled for 0.8.2.2 so make sure zookeeper root that you're using doesn't have any acls set
-Harsha On Sun, Feb 14, 2016, at 06:51 PM, 赵景波 wrote: > Can you help me? > > _______________________________________________________________ > JingBo Zhao<http://weibo.com/zbdba> – 赵景波 > jing...@staff.sina.com.cn<mailto:jing...@staff.sina.com.cn> > > 研发中心 - 平台架构部 - 数据库平台 - DBA > （手机）18610917066 > Add.: 北京市海淀区北四环西路58号理想国际大厦17层 > _______________________________________________________________ > > 发件人: 赵景波 > 发送时间: 2016年2月2日 17:04 > 收件人: 'users@kafka.apache.org' <users@kafka.apache.org> > 主题: 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> – 赵景波 > jing...@staff.sina.com.cn<mailto:jing...@staff.sina.com.cn> > > 研发中心 - 平台架构部 - 数据库平台 - DBA > （手机）18610917066 > Add.: 北京市海淀区北四环西路58号理想国际大厦17层 > _______________________________________________________________ >
