Home | About | Sematext search-lucene.com search-hadoop.com
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
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> how to configure zk.connect in 0.7.2


Copy link to this message
-
Re: how to configure zk.connect in 0.7.2
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
王国栋

 
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