Kafka, mail # user - Re: How to create the initial zookeeper chroot path for zk.connect? - 2013-04-20, 09:24
 Search Hadoop and all its subprojects:

Switch to Threaded View
Copy link to this message
-
Re: How to create the initial zookeeper chroot path for zk.connect?
Hello,

Tried, still the same...
bin/zkCli.sh -server zookeeper1:2181,zookeeper2:2181,zookeeper3:2181
[zk: zookeeper1,zookeeper2,zookeeper3(CONNECTED) 0]  ls /
[testkafka, consumers, brokers, zookeeper]
[zk: zookeeper1,zookeeper2,zookeeper3(CONNECTED) 1] rmr /testkafka
[zk: zookeeper1,zookeeper2,zookeeper3(CONNECTED) 2] create /testkafka ''
[zk: zookeeper1,zookeeper2,zookeeper3(CONNECTED) 3] ls /
[testkafka, consumers, brokers, zookeeper]

And restart Kafka

[2013-04-20 09:20:58,336] FATAL Fatal error during KafkaServerStable
startup. Prepare to shutdown (kafka.server.KafkaServerStartable)
java.lang.IllegalArgumentException: Path length must be > 0
at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:626)
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)
at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:47)
at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:59)
at kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:71)
at kafka.server.KafkaZooKeeper.registerBrokerInZk(KafkaZooKeeper.scala:54)
at kafka.log.LogManager.startup(LogManager.scala:130)
at kafka.server.KafkaServer.startup(KafkaServer.scala:81)
at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:34)
at kafka.Kafka$.main(Kafka.scala:47)
at kafka.Kafka.main(Kafka.scala)

Maybe I should report a bug?
(I posted here first just to know if I have done sth stupid)
On Sat, Apr 20, 2013 at 1:02 PM, Neha Narkhede <[EMAIL PROTECTED]>wrote:
 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB