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: "陈小军"&lt;chenxiao...@nhn.com&gt;
> To: &lt;users@kafka.apache.org&gt;;
> 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  --&gt; leader : 1; partition 1  --&gt; leader :
> 2;partition 2  --&gt; leader : 3
>
>  but this morning, I check the status of kafka, the leader of partitions
> changed
>    topicA : partition 0  --&gt; leader : 2 ; partition 1  --&gt; leader :
> 2;partition 2  --&gt; 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

Reply via email to