是指手动写扩充replicas的配置文件,然后使用工具进行操作。

   参考官网site:http://kafka.apache.org/documentation.html#basic_ops_automigrate

  1.首先创建一个三分区一副本的topic,并查看详细信息:

     kafka中对一个topic增加replicas

  2.修改配置文件

    将原有replicas为[0]扩充为[0,1], [1]扩充为[1,2],[2]扩充为[2,0,1] 

    > cat partitions-to-move.json

    kafka中对一个topic增加replicas

  3.执行操作,并检查修改情况

    > bin/kafka-reassign-partitions.sh --zookeeper h1:2181 --reassignment-json-file partitions-to-move.json --execute

    > bin/kafka-topics.sh --describe --zookeeper h1:2181  --topic test-add-replication-topic

    kafka中对一个topic增加replicas

    由于太长,只截取了部分信息

  

  

相关文章:

  • 2022-12-23
  • 2022-12-23
  • 2021-09-21
  • 2022-02-17
  • 2022-12-23
  • 2021-08-15
  • 2022-02-08
  • 2021-07-26
猜你喜欢
  • 2022-02-22
  • 2022-12-23
  • 2021-10-19
  • 2021-10-19
  • 2021-08-15
  • 2021-08-15
  • 2021-08-20
相关资源
相似解决方案