kafka手动重新分配partition

1.编写要重新分配的topic的json配置文件

{

    "topics": [

        {"topic":"test"}

        ],

    "version":1

}

2.调用--generate生成迁移计划，将test扩充到所有机器上

./bin/kafka-reassign-partitions.sh --zookeeper vlnx111122:2181 --topics-to-move-json-file topic.json  --broker-list"1,2,3,4,5"--generate 

输出如下：

Current partition replica assignment

{"version":1,

"partitions":[....]

}

Proposed partition reassignment configuration

{"version":1,

"partitions":[.....]

}

3.将迁移后的json存入一个文件reassignment.json，供--execute命令使用

./bin/kafka-reassign-partitions.sh --zookeeper vlnx111122:2181 --reassignment-json-file reassignment.json --execute

4.使用--verify查看进度

./bin/kafka-reassign-partitions.sh --zookeeper vlnx111122:2181 --reassignment-json-file reassignment.json --verify