Kafka节点扩容、缩容后reassign partition

• • 简介
  • kafka-reassign-partitions使用

kafka节点扩容、缩容后，需要reassign partition replica，

• –generate 生成partition replica分配计划

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

• –execute 执行重新分配

 ./kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file /opt/apps/ecm/service/kafka/2.11-1.1.1-1.3.3/package/kafka_2.11-1.1.1-1.3.3/bin/1.json --execute

• –verify 查看分配进度

 ./kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file /opt/apps/ecm/service/kafka/2.11-1.1.1-1.3.3/package/kafka_2.11-1.1.1-1.3.3/bin/1.json --verify