Re: Question on Kafka partitions.

2013-09-13 Thread Neha Narkhede
This means broker 1 is the controller. It uses a generic zookeeper based leader election module which is where this log4j message is coming from. Thanks, Neha On Sep 12, 2013 10:52 PM, "Lu Xuechao" wrote: > Thanks Rao. I found both log.dir and log.dirs worked. > > When I start up all my brokers,

Re: Question on Kafka partitions.

2013-09-13 Thread Jun Rao
This indicates the controller (see the end of http://kafka.apache.org/documentation.html#replication) of the cluster. Thanks, Jun On Thu, Sep 12, 2013 at 5:29 PM, Lu Xuechao wrote: > Thanks Rao. I found both log.dir and log.dirs worked. > > When I start up all my brokers, I see below log mess

Re: Question on Kafka partitions.

2013-09-12 Thread Lu Xuechao
Thanks Rao. I found both log.dir and log.dirs worked. When I start up all my brokers, I see below log message on the console of broker 1: What does that mean? Partition leader or not? [2013-09-12 13:10:54,570] INFO New leader is 1 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener) On Th

Re: Question on Kafka partitions.

2013-09-11 Thread Jun Rao
1. You can put multiple directories, each on a separate volume, in log.dirs. 2. Yes, our replica assignment logic will try to spread the partitions and the leaders evenly among the brokers. Thanks, Jun On Wed, Sep 11, 2013 at 9:59 PM, Lu Xuechao wrote: > Hi Team, > > I have some questions re