kafka 调整topic所在的分区 kafka-reassign-partitionssh

kafka-reassign-partitions.sh 是 Kafka 提供的一个脚本工具，用于重新分配 Kafka 集群中的分区。

使用 kafka-reassign-partitions.sh 可以调整一个或多个 topic 所在的分区，以实现分区的重新分布或者平衡。这对于扩展 Kafka 集群的容量或者调整数据流量分布等场景非常有用。

使用 kafka-reassign-partitions.sh 需要以下步骤：

1. 创建一个 JSON 文件，指定要进行分区重新分配的 topic、分区和对应的副本分配方案。该文件的格式如下：

{
  "version":1,
  "partitions":[
    {"topic":"topic1", "partition":0, "replicas":[1,2,3]},
    {"topic":"topic1", "partition":1, "replicas":[2,3,4]},
    ...
  ]
}

2. 执行以下命令来启动分区重新分配：

kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file reassignment.json --execute

其中，--zookeeper 参数指定了 ZooKeeper 的连接地址，--reassignment-json-file 参数指定了分区重新分配方案的 JSON 文件，--execute 参数表示执行分区重新分配。

3. 查看分区重新分配的状态：

kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file reassignment.json --verify

该命令将会显示分区重新分配的状态，包括每个分区的当前和目标副本分配情况。

4. 完成分区重新分配后，可以执行以下命令来删除分区重新分配的状态：

kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file reassignment.json --remove

该命令将会删除分区重新分配的状态信息。

需要注意的是，执行分区重新分配会涉及到 Kafka 集群的数据迁移，可能会对集群的性能产生影响，因此在生产环境中需要谨慎操作，并确保集群具备足够的容量和资源