如何重新平衡部分分区的主题

3htmauhk  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(224)

假设我想重新平衡主题- cars_data_hibrid_machines 在我的 kafka 集群
我们有6个Kafka经纪人 cars_data_hibrid_machines 包括 200 分区和复制 factor is 3 在这种情况下,我将创建以下 car.json ```
{
"version": 1,
"topics": [
{ "topic": "cars_data_hibrid_machines"
]
}

那么
我们运行以下命令

kafka-reassign-partitions.sh --zookeeper $ZK_HOSTS --topics-to-move-json-file car.json --broker-list "1,2,3,4,5,6" --generate

kafka-reassign-partitions.sh --zookeeper $ZK_HOSTS --reassignment-json-file reassignment.json –execute

现在假设我们只想重新平衡第一个 `20 partitions` 关于这个主题- `cars_data_hibrid_machines` 在我的Kafka星团上
在这种情况下,如何使用主题分区构建json文件?
主题分区示例

Topic: cars_data_hibrid_machines Partition: 0 Leader: 5 Replicas: 5,1,2 Isr: 5,2,1
Topic: cars_data_hibrid_machines Partition: 1 Leader: 6 Replicas: 6,2,3 Isr: 6,2,3
Topic: cars_data_hibrid_machines Partition: 2 Leader: 1 Replicas: 1,3,4 Isr: 4,1,3
Topic: cars_data_hibrid_machines Partition: 3 Leader: 2 Replicas: 2,4,5 Isr: 4,5,2
Topic: cars_data_hibrid_machines Partition: 4 Leader: 3 Replicas: 3,5,6 Isr: 5,6,3
Topic: cars_data_hibrid_machines Partition: 5 Leader: 4 Replicas: 4,6,1 Isr: 4,6,1

.
.
.
.
.
.

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题