Kafka权威指南

管理

Kafka

｜

147

{

"partitions": [

{

"partition": 1,

"topic": "foo"

},

{

"partition": 2,

"topic": "foobar"

}

]

}

示例：通过在

partitions.json

文件里指定分区清单来启动副本选举。

# kafka-preferred-replica-election.sh --zookeeper

zoo1.example.com:2181/kafka-cluster --path-to-json-file

partitions.json

Successfully started preferred replica election for partitions

Set([my-topic,1], [my-topic,2], [my-topic,3])

#

9.4.2

　修改分区副本

在某些时候，可能需要修改分区的副本。以下是一些需要修改分区副本的场景。

•

主题分区在整个集群里的不均衡分布造成了集群负载的不均衡。

• broker

离线造成分区不同步。

•

新加入的

broker

需要从集群里获得负载。

可以使用

kafka-reassign-partitions.sh

工具来修改分区。使用该工具需要经过两个步骤：第

一步，根据

broker

清单和主题清单生成一组迁移步骤；第二步，执行这些迁移步骤。第三

个步骤是可选的，也就是可以使用生成的迁移步骤验证分区重分配的进度和完成情况。

为了生成迁移步骤，需要先创建一个包含了主题清单的 ...