Kafka:增加Topic主题副本数量

朱雀 2024-03-25 21:51 171阅读 0赞

在生产环境当中,由于某个主题的重要等级需要提升,我们考虑增加副本。副本数的增加需要先制定计划,然后根据计划执行。

1)创建 topic test
  1. bin/kafka-topics.sh --bootstrap-server 192.168.25.129:9092 --create --partitions 3 --replication-factor 1 --topic test
2)手动增加副本存储
(1)创建副本存储计划(所有副本都指定存储在 broker0、broker1、broker2 中)。
  1. vim increase-replication-factor.json

输入如下内容:

  1. {
  2. "version":1,
  3. "partitions":[
  4. {"topic":"test",
  5. "partition":0,
  6. "replicas":[0,1,2]},
  7. {"topic":"test",
  8. "partition":1,
  9. "replicas":[0,1,2]
  10. },
  11. {"topic":"test",
  12. "partition":2,
  13. "replicas":[0,1,2]
  14. }
  15. ]
  16. }
(2)执行副本存储计划。
  1. bin/kafka-reassign-partitions.sh --bootstrap-server 192.168.25.129:9092 --reassignment-json-file increase-replication-factor.json --execute

发表评论

表情:
评论列表 (有 0 条评论,171人围观)

还没有评论,来说两句吧...

相关阅读