在Kafka中修改Topic的preferred replica

參考site：https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools

目前我們的topic  test-add-replication-topic中partition 0的replicas為[1,2]，則1為preferred replica，應該成為leader。 
這時我們期望2為preferred replica，並變成leader。

操作步驟：

1. 查看當前topic詳細信息：

　　> bin/kafka-topics.sh --describe --zookeeper h1:2181 --topic test-add-replication-topic

　　　　Topic:test-add-replication-topic PartitionCount:3 ReplicationFactor:3 Configs:

　　　　　　Topic: test-add-replication-topic Partition: 0 Leader: 1 Replicas: 1,2 Isr: 1,2

　　　　　　Topic: test-add-replication-topic Partition: 1 Leader: 2 Replicas: 2,0,1 Isr: 0,1,2
　　　　　　Topic: test-add-replication-topic Partition: 2 Leader: 0 Replicas: 0,1 Isr: 0,1

2. 修改replicas順序

　　> cat partitions-to-move.json 

　　　　{ 

　　　　　　"version":1,
　　　　　　"partitions":
　　　　　　[
　　　　　　{
　　　　　　　　"topic":"test-add-replication-topic",
　　　　　　　　"partition":0,
　　　　　　　　"replicas":[2,1]
　　　　　　}
　　　　　　]
　　　　}

　　> bin/kafka-reassign-partitions.sh --zookeeper h1:2181 --reassignment-json-file partitions-to-move.json --execute

　　　　Current partition replica assignment

　　　　{"version":1,"partitions":[{"topic":"test-add-replication-topic","partition":1,"replicas":[2,0,1]},{"topic":"test-add-replication-topic","partition":2,"replicas":[0,1]},

　　　　{"topic":"test-add-replication-topic","partition":0,"replicas":[1,2]}]}

　　　　Save this to use as the --reassignment-json-file option during rollback
　　　　Successfully started reassignment of partitions {"version":1,"partitions":[{"topic":"test-add-replication-topic","partition":0,"replicas":[2,1]}]}

3. 更改leader

　　> cat topicPartition.json 

　　　　{
　　　　　　"version":1,
　　　　　　"partitions":
　　　　　　[
　　　　　　{
　　　　　　　　"topic":"test-add-replication-topic",
　　　　　　　　"partition":0
　　　　　　}
　　　　　　]
　　　　}

　　> bin/kafka-preferred-replica-election.sh --zookeeper h1:2181 --path-to-json-file topicPartition.json 

　　　　Successfully started preferred replica election for partitions Set([test-add-replication-topic,0])

4.檢查replicas leader切換情況 

　　> bin/kafka-topics.sh --describe --zookeeper h1:2181 --topic test-add-replication-topic

　　　　Topic:test-add-replication-topic PartitionCount:3 ReplicationFactor:3 Configs:

　　　　　　Topic: test-add-replication-topic Partition: 0 Leader: 2 Replicas: 2,1 Isr: 1,2
　　　　　　Topic: test-add-replication-topic Partition: 1 Leader: 2 Replicas: 2,0,1 Isr: 0,1,2
　　　　　　Topic: test-add-replication-topic Partition: 2 Leader: 0 Replicas: 0,1 Isr: 0,1

  到此，partition 0中的leader已經修改成功。