Kafka:增加Topic主题副本数量
在生产环境当中,由于某个主题的重要等级需要提升,我们考虑增加副本。副本数的增加需要先制定计划,然后根据计划执行。
1)创建 topic test
bin/kafka-topics.sh --bootstrap-server 192.168.25.129:9092 --create --partitions 3 --replication-factor 1 --topic test
2)手动增加副本存储
(1)创建副本存储计划(所有副本都指定存储在 broker0、broker1、broker2 中)。
vim increase-replication-factor.json
输入如下内容:
{
"version":1,
"partitions":[
{"topic":"test",
"partition":0,
"replicas":[0,1,2]},
{"topic":"test",
"partition":1,
"replicas":[0,1,2]
},
{"topic":"test",
"partition":2,
"replicas":[0,1,2]
}
]
}
(2)执行副本存储计划。
bin/kafka-reassign-partitions.sh --bootstrap-server 192.168.25.129:9092 --reassignment-json-file increase-replication-factor.json --execute
还没有评论,来说两句吧...