Re: kafka leader automatic changed

2014-02-17 Thread Guozhang Wang
2-18 00:27:55,882] INFO New leader is 2 > (kafka.server.ZookeeperLeaderElector$LeaderChangeListener) > > Best Regards > Jerry > -Original Message- > From: "陈小军"<chenxiao...@nhn.com> > To: <users@kafka.apache.org>; > Cc: > Sent: 2014-02-18 (星期二) 10:4

RE: kafka leader automatic changed

2014-02-17 Thread 陈小军
(kafka.server.ZookeeperLeaderElector) [2014-02-18 00:27:55,882] INFO New leader is 2 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener) Best Regards Jerry -Original Message- From: "陈小军"<chenxiao...@nhn.com> To: <users@kafka.apache.org>; Cc: Sent: 2014-02-18 (星期二) 10:41:00

kafka leader automatic changed

2014-02-17 Thread 陈小军
Hi, I running kafka 0.8.1 branch code. in my test env, I have 3 servers (broker 1, 2, 3), and create three topics with 3 partitions and 2 replica for each partition. at beginning each partition's leader is allocated to different server. topicA : partition 0 --> leader : 1; partition 1 -