如何为一个主题增加分区的数量，改变每个分区的领导者并重新平衡它们

Question

如果我们有一个主题在Kafka，它有5个分区，我们可以增加到30个分区。另外，在增加分区的数量之后，我们按照代理ID的顺序更改每个分区的领导者，并为该特定主题重新平衡集群。我们怎么能那样做？

Answer 1

我发现了它的工作原理。

1）首先查找已有主题的信息

2）找出集群中的所有代理及其ID

提供所有代理ID的列表

3）./kafka-topics.sh--alter--zookeeper localhost：2181--topic dummytopic--partitions 30

增加分区数

开始生成&&topic=dummytopic num_partitions=30brokerid_start=1022 replica_count=3./kafka-resignment-gen

这将生成一个json，我们可以将它用于expand-cluster-reassignment.json。看起来是这样的

{“版本”：1,“分区”：[{“话题”：“dummyTopic”,“分区”：0,“副本”：[1001,1002,1003]},{“话题”：“dummyTopic”,“分区”：1,“副本”：[1002,1003,1004]},{“话题”：“dummyTopic”,“分区”：2,“副本”：[1003,1004,1005]},{“话题”：“dummyTopic”,“分区”：3,“副本”：[1004,1005,1006]},{“话题”：“dummyTopic”,“分区”：4,“副本”：[1005,1006,1007]},{“1017]},{“topic”：“dummytopic”,“partition”：15,“replicas”：[1016,1017,1018]},{“topic”：“dummytopic”,“partition”：16,“replicas”：[1017,1018,1019]},{“topic”：“dummytopic”,“partition”：17,“replicas”：[1018,1019,1020]},{“topic”：“dummytopic”,“partition”：18,“replicas”：[1019,1020,1021]},{“topic”：“

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

这将执行集群重新分配，并将分区领导者更改为您所期望的。