Hello Jerry, Does this answers your question?
https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Whypartitionleadersmigratethemselvessometimes ? Guozhang On Mon, Feb 17, 2014 at 5:46 PM, 陈小军 <chenxiao...@nhn.com> wrote: > add I found some log from server.log > > [2014-02-18 00:27:54,460] INFO re-registering broker info in ZK for broker > 2 (kafka.server.KafkaHealthcheck) > [2014-02-18 00:27:54,477] INFO Registered broker 2 at path /brokers/ids/2 > with address xseed133.kdev.nhnsystem.com:9093. (kafka.utils.ZkUtils$) > [2014-02-18 00:27:54,481] INFO done re-registering broker > (kafka.server.KafkaHealthcheck) > [2014-02-18 00:27:54,483] INFO Subscribing to /brokers/topics path to > watch for new topics (kafka.server.KafkaHealthcheck) > [2014-02-18 00:27:54,614] INFO 2 successfully elected as leader > (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 > Subject: kafka leader automatic changed > > 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 --> leader : > 2;partition 2 --> leader : 3 > > but this morning, I check the status of kafka, the leader of partitions > changed > topicA : partition 0 --> leader : 2 ; partition 1 --> leader : > 2;partition 2 --> leader : 3 > > > I don't why this situation happend. during the night there is no data > send to kafka. > Does someone know about this? > > Thanks~! > > > Best Regards > Jerry > -- -- Guozhang