Re: Specify leader when doing partition reassignment

2015-08-05 Thread tao xiao
Thank you Todd for the detailed answer On Wed, Aug 5, 2015 at 9:09 PM Todd Palino wrote: > To make sure you have a complete answer here, the order of the replica list > that you specify in the partition reassignment will affect the leader > selection, but if the current leader is in the new repli

Re: Specify leader when doing partition reassignment

2015-08-05 Thread Todd Palino
To make sure you have a complete answer here, the order of the replica list that you specify in the partition reassignment will affect the leader selection, but if the current leader is in the new replica list, it will not change the leadership to change. That is, if your current replica list is [

Re: Specify leader when doing partition reassignment

2015-08-05 Thread tao xiao
I think I figured it out. As pointed out in https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools#Replicationtools-6.ReassignPartitionsTool If the leader is not in the reassigned replica a new leader will be elected and the tool doesn't pick the first one from the RAR as the leader

Re: Specify leader when doing partition reassignment

2015-08-05 Thread Jilin Xie
Check the --replica-assignment parameter of the kafka-topics.sh. It does what you need. And there should also be similar configs in the api if you wanna do so by coding. On Wed, Aug 5, 2015 at 6:18 PM, tao xiao wrote: > Hi team, > > Is it possible to specify a leader broker for each topic parti

Specify leader when doing partition reassignment

2015-08-05 Thread tao xiao
Hi team, Is it possible to specify a leader broker for each topic partition when doing partition reassignment? For example I have following json. Is the first broker in the replicas list by default the leader of the partition e.g. broker 3 is the leader of topic test5 and broker 2 is the leader o