1. 查看topic的描述
#./kafka-topics.sh --describe --zookeeper snn:2181 --topictest-qt-001
2. 编写副本再赋值脚本
创建文本文件”partitions-to-move.json”,
# vim partitions-to-move.json.json
输入文本:
{
“version”:1,
“partitions”:[
{“topic”:”test-qt-001”, “partition”:0, “replicas”:[1002, 1003]}
…
]
}
3. 执行
./kafka-reassign-partitions.sh --zookeeper snn:2181 --reassignment-json-file partitions-to-move.json –execute
4. 查看
./kafka-topics.sh --describe --zookeeper snn:2181 --topictest-qt-001