Hmm, so if you use all 3 zookeeper servers will creating and reading the node, do you still see the problem ?
zkCli.sh -server zookeeper1:2181,zookeeper2:2181,zookeeper3:2181 create /testkafka ls / Thanks Neha On Fri, Apr 19, 2013 at 8:55 PM, Ryan Chan <ryanchan...@gmail.com> wrote: > Hi, > > Actually I followed the above link to setup my zookeeper1 to zookeeper3. > > They are in the same quorum, as you can see in my above example that when I > created the /testkafka path in zookeeper1, I can see list it in zookeeper2 > > Thanks > > > On Sat, Apr 20, 2013 at 12:08 AM, Neha Narkhede > <neha.narkh...@gmail.com>wrote: > >> I'm pretty sure the issue is that those 3 zookeepers are not part of >> the same quorum. Try following the quickstart for starting up a local >> zookeeper instance or follow >> >> http://zookeeper.apache.org/doc/r3.3.3/zookeeperAdmin.html#sc_zkMulitServerSetup >> for a zookeeper cluster setup. >> >> Thanks, >> Neha >> >> On Thu, Apr 18, 2013 at 10:50 PM, Jonathan Creasy <j...@box.com> wrote: >> > I made the patch to create the chroot and it doesn't handle multiple zk >> > addresses. >> > >> > We fixed it but I guess that patch didn't get submitted. I will make a >> > ticket here to get that done. >> > On Apr 18, 2013 10:47 PM, "Ryan Chan" <ryanchan...@gmail.com> wrote: >> > >> >> Yes, using the latest Kafka 0.7.2, just tried to reproduce again >> >> >> >> 1. Install a single node Kafka, three nodes zookeeper instances >> >> >> >> kafka1 >> >> zookeeper1 >> >> zookeeper2 >> >> zookeeper3 >> >> >> >> 2. Using a simple Kafka config, able to start without error in the log >> >> >> >> brokerid=1 >> >> log.dir=/data/kafka >> >> zk.connect=zookeeper1:2181,zookeeper2:2181,zookeeper3:2181 >> >> >> >> 3. Now, create a path in zookeeper1 >> >> >> >> zkCli.sh -server zookeeper1:2181 >> >> >> >> ls / >> >> [consumers, brokers, zookeeper] >> >> create /testkafka '' >> >> ls / >> >> [testkafka, consumers, brokers, zookeeper] >> >> >> >> Quit & Done. >> >> >> >> 4. Verify from zookeeper2 >> >> >> >> zkCli.sh -server zookeeper2:2181 >> >> ls / >> >> [testkafka, consumers, brokers, zookeeper] >> >> >> >> Seems ok >> >> >> >> 4. Update kafka config and restart >> >> >> >> >> >> >> >> >> zk.connect=zookeeper1:2181/testkafka,zookeeper2:2181/testkafka,zookeeper3:2181/testkafka >> >> >> >> Restart and have the error >> >> >> >> [2013-04-19 05:35:14,846] 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) >> >> .. >> >> >> >> >> >> Any idea? >> >> >> >> >> >> >> >> >> >> On Fri, Apr 19, 2013 at 5:32 AM, Neha Narkhede <neha.narkh...@gmail.com >> >> >wrote: >> >> >> >> > That is odd. Is it reproducible ? >> >> > >> >> > On Wed, Apr 17, 2013 at 8:03 PM, Ryan Chan <ryanchan...@gmail.com> >> >> wrote: >> >> > > Hi, >> >> > > >> >> > > Yes, I can see the new path exists by using the command "ls /" >> >> > > >> >> > > >> >> > > >> >> > > On Thu, Apr 18, 2013 at 1:29 AM, Neha Narkhede < >> >> neha.narkh...@gmail.com >> >> > >wrote: >> >> > > >> >> > >> After creating the path, did you get a chance to confirm that it >> got >> >> > >> created correctly ? >> >> > >> >> >> > >> Thanks, >> >> > >> Neha >> >> > >> >> >> > >> On Wed, Apr 17, 2013 at 9:30 AM, Ryan Chan <ryanchan...@gmail.com> >> >> > wrote: >> >> > >> > Sorry as I am new to Kafka/ZK, but the instruction seems not >> clear.. >> >> > >> > >> >> > >> > In the config, it was said that we can use a chroot-ed ZK ( >> >> > >> > http://kafka.apache.org/configuration.html), e.g. >> >> > localhost:2181/kafka >> >> > >> > >> >> > >> > But when I start the Kafka using the setting, it was showing.. >> >> > >> > >> >> > >> > 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) >> >> > >> > >> >> > >> > In an old post ( >> >> > >> > >> >> > >> >> >> > >> >> >> http://mail-archives.apache.org/mod_mbox/incubator-kafka-users/201205.mbox/%3CCAK152briB=m-oaeaqtcz+cvzjovywbhomx8tubywqguox_y...@mail.gmail.com%3E >> >> > >> ) >> >> > >> > it was saying I need to create the path first, so I use zkCli.sh >> to >> >> > >> connect >> >> > >> > to the ZK, and run the command >> >> > >> > >> >> > >> >>> create /kafka '' >> >> > >> > >> >> > >> > I restarted the Kafka and still the same error, any idea? >> >> > >> > >> >> > >> > Thanks. >> >> > >> >> >> > >> >> >>
