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
