kafka手动重新分配partition
2019-08-16 本文已影响0人
mrknowledge
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
