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

Switch to Threaded View
Kafka, mail # user - Re: how to configure zk.connect in 0.7.2


Copy link to this message
-
Re: how to configure zk.connect in 0.7.2
王国栋 2013-03-13, 03:21
Thanks Jun. It works~
On Wed, Mar 13, 2013 at 1:14 AM, Jun Rao <[EMAIL PROTECTED]> wrote:

> You should set it to the following, with namespace only specified at the
> end:
> zk8sh.prod.mediav.com:2191,zk9sh.prod.mediav.com:2191,
> zk10sh.prod.mediav.com:2191/kafka<
> http://zk8sh.prod.mediav.com:2191/kafka,zk9sh.prod.mediav.com:2191/kafka,zk10sh.prod.mediav.com:2191/kafka
> >
>
> Thanks,
>
> Jun
>
> On Tue, Mar 12, 2013 at 2:08 AM, 王国栋 <[EMAIL PROTECTED]> wrote:
>
> > Hi guys,
> >
> > I am using kafka0.7.2 now, and I configure zk.connect as "zk.connect=
> >
> >
> zk8sh.prod.mediav.com:2191/kafka,zk9sh.prod.mediav.com:2191/kafka,zk10sh.prod.mediav.com:2191/kafka
> > "
> > And the broker can not be started.
> >
> > The error message is as follow. I think the messages I highlighted show
> > that I can not set multiple zk-hosts with root path.
> > I have tried to use a single host with root path, it is OK.
> >
> > If I want to use multiple hosts with root path, how can I configure
> > zk.connect ?
> >
> > Thanks a lot.
> >
> > 226  [main-SendThread(zk8sh.prod.mediav.com:2191)] DEBUG
> > org.apache.zookeeper.ClientCnxn  - Reading reply sessionid:0x13d1a553b8
> > 9237d, packet:: clientPath:null serverPath:null finished:false header::
> 1,1
> >  replyHeader:: 1,8589958761,-101  request:: '*/kafka%*
> > *
> >
> >
> 2Czk9sh.prod.mediav.com:2191/kafka%2Czk10sh.prod.mediav.com:2191/kafka/brokers/ids/0
> > *,#6b663173682e70726f642e6d65646961762e636f6d
> >
> >
> 2d313336333037383639353937353a6b663173682e70726f642e6d65646961762e636f6d3a39303932,v{s{31,s{'world,'anyone}}},1
> >  response::
> > 240  [main-SendThread(zk8sh.prod.mediav.com:2191)] DEBUG
> > org.apache.zookeeper.ClientCnxn  - Reading reply sessionid:0x13d1a553b8
> > 9237d, packet:: clientPath:null serverPath:null finished:false header::
> 2,1
> >  replyHeader:: 2,8589958762,-101  request:: '*/kafka%*
> > *
> >
> >
> 2Czk9sh.prod.mediav.com:2191/kafka%2Czk10sh.prod.mediav.com:2191/kafka/brokers/ids
> > *,,v{s{31,s{'world,'anyone}}},0  response::
> > 249  [main-SendThread(zk8sh.prod.mediav.com:2191)] DEBUG
> > org.apache.zookeeper.ClientCnxn  - Reading reply sessionid:0x13d1a553b8
> > 9237d, packet:: clientPath:null serverPath:null finished:false header::
> 3,1
> >  replyHeader:: 3,8589958763,-101  request:: '/kafka%
> >
> >
> 2Czk9sh.prod.mediav.com:2191/kafka%2Czk10sh.prod.mediav.com:2191/kafka/brokers,,v{s{31,s{'world,'anyone}}},0
> > response::
> > 251  [main] FATAL kafka.server.KafkaServerStartable  - Fatal error during
> > KafkaServerStable startup. Prepare to shutdown
> > 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)

Guodong Wang
王国栋