假设我想重新平衡主题- 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
.
.
.
.
.
.
暂无答案!
目前还没有任何答案,快来回答吧!