Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> How to create the initial zookeeper chroot path for zk.connect?


Copy link to this message
-
Re: How to create the initial zookeeper chroot path for zk.connect?
Since There is only 1 chroot for a zk cluster, if you specified for each server there would be a potential for error/mismatch

Things would probably go really bad if you had mismatched chroots :)

Sent from my iPhone

On Apr 21, 2013, at 1:34 AM, Ryan Chan <[EMAIL PROTECTED]> wrote:

> Thanks, this solved the problem.
>
> But the connection string as "Zk1:2181,zk2:2181,zk3;2181/Kafka", seems
> unintuitive?
>
>
> On Sun, Apr 21, 2013 at 2:29 AM, Scott Clasen <[EMAIL PROTECTED]> wrote:
>
>> Afaik you only put the chroot on the end of the zk conn str...
>>
>> Zk1:2181,zk2:2181,zk3;2181/Kafka
>>
>> Not
>>
>> Zk1:2181/kafka,zk2:2181/Kafka,zk3:2181/Kafka
>>
>>
>> Sent from my iPhone
>>
>> On Apr 20, 2013, at 9:03 AM, Neha Narkhede <[EMAIL PROTECTED]>
>> wrote:
>>
>>> Please file a bug and mention the Kafka and zookeeper versions used for
>> the
>>> test.
>>>
>>> Thanks,
>>> Neha
>>>
>>> On Saturday, April 20, 2013, Ryan Chan wrote:
>>>
>>>> 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]
>> <javascript:;>
>>>>> wrote:
>>>>
>>>>> 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 <[EMAIL PROTECTED]>
>>>> 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
>>>>>>
>