之前的文章讲述了Kafka的分区重分配,该方法同样可以用来增加或减少Kafka topic的副本数。该方法,可灵活地运用于提高topic的高可用性,提高数据的读写等场景。

目录

从一个副本数,增加到2个副本数。

再增加一个副本,达到3个副本数


  • 从一个副本数,增加到2个副本数。

创建reassign.json文件

{"version":1,"partitions":[{"topic":"topic_replica_test","partition":0,"replicas":[164,150]},{"topic":"topic_replica_test","partition":1,"replicas":[165,151]},{"topic":"topic_replica_test","partition":2,"replicas":[150,152]}]}

执行重分配操作

kafka-reassign-partitions --zookeeper zk1:2181 --reassignment-json-file reassign.json --execute

输出会显示当前partition的分布Current partition replica assignment,可以保存下来以便有问题进行回滚。

再次查看topic的partiton分布和replica数可以看到,已经增加了副本。

kafka-topics --zookeeper zk1:2181 --topic topic_replica_test --describe

  • 再增加一个副本,达到3个副本数

kafka-reassign-partitions --zookeeper zk1:2181 --reassignment-json-file reassign.json --execute

如果topic数据量比较大,可能调整副本数的过程会非常慢,可以用verify命令查询进度。

kafka-reassign-partitions --zookeeper zk1:2181 --reassignment-json-file reassign.json --verify

再次查看topic的partiton分布和replica数可以看到,已经增加了3个副本。

kafka-topics --zookeeper zk1:2181 --topic topic_replica_test --describe

欢迎关注我的公众号“九万里大数据”,原创技术文章第一时间推送。

欢迎访问原创技术博客网站 jwldata.com,排版更清晰,阅读更爽快。

增加(或减少)Kafka topic的副本数相关推荐

  1. kafka 在线修改副本数

    背景  前段时间由于集群各台机器配置不一样,导致部分机器磁盘吃紧.定位发现kafka log数据占了一半的容量,而且某一个topic的数据惊人,50个partition,每个partition24G, ...

  2. 5、kubernetes Scale Up/Down在线增加或减少 Pod 的副本数、Failover故障转移、用 label(标签)控制 Pod 的位置

    伸缩(Scale Up/Down)是指在线增加或减少 Pod 的副本数. Deployment nginx-app 初始是两个副本 [root@master ~]# kubectl apply -f ...

  3. kafka修改分区数_ELK|kafka增加分区或调整副本数

    Sommaire de cet article : kafak管理常用的工具是kafka-manager和kakfa-eagle.这两个工具在分区管理上都是只管加不管减,副本调整的话,也不支持,只能自 ...

  4. 为什么Kafka中的分区数只能增加不能减少?

    作者:朱小厮 来源:朱小厮的博客 当一个主题被创建之后,依然允许我们对其做一定的修改,比如修改分区个数.修改配置等,这个修改的功能就是由kafka-topics.sh脚本中的alter指令所提供.我们 ...

  5. Kafka topic分区增加副本

    Kafka中topic的每个分区可以设置多个副本.如果副本数为1,当该分区副本的leader节点宕机后,会导致该分区不可用.故需要设置多副本来保证可用性. 实际项目中,存在项目初期创建了副本数为1的t ...

  6. kafka 修改分区_kafka修改分区和副本数

    kafka修改分区和副本数 查看现在副本分配情况 ../bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --describe --topic test1 ...

  7. hdfs的副本数为啥增加了_设置hdfs副本数 dfs.replication

    设置hdfs副本数 dfs.replication 有个临时应用,使用临时调配的机器,机器磁盘差别数十倍. 在使用hadoop存储数据时导致小磁盘机器使用率达80%多,而大磁盘机器使用不过才10%多一 ...

  8. hdfs的副本数为啥增加了_HDFS详解之块大小和副本数

    1.HDFS HDFS : 伪分布式(学习) NN DN SNN sbin/start-dfs.sh(开启hdfs使用的脚本) bin/hdfs dfs -ls (输入命令加前缀bin/hdfs df ...

  9. hdfs的副本数为啥增加了_HDFS架构小结

    分布式文件系统 - Hadoop Distributed File System (HDFS)运行于通用硬件上的分布式文件系统,高吞吐,高可靠. HDFS架构 HDFS主要由NameNode.Seco ...

最新文章

  1. confluence mysql 中文乱码_解决confluence的乱码问题
  2. oracle 怎么创建约束,Oracle创建约束
  3. MYSQL || 的BUG // MYSQL 不同库自增id的问题 //MySQL根据表注释查找对应的表 //hive -mysql 日期比较
  4. ALV调用标准GUI STATUS
  5. JSjQuery全选反选父项子项联动多选框
  6. 软件工程概论 课堂练习【用例图——客户提出申请要求贷款...】
  7. Centos安装后的一些必要处理工作
  8. 结对项目 - 词频统计
  9. 2018年机器学习趋势与Apache Kafka生态系统相结合
  10. idea运行报错Parameter ‘name‘ not found. Available parameters are [arg1, arg0, param1, param2]
  11. 【分布计算环境学习笔记】3 软件构件结构
  12. 20161013 晨报
  13. python3、ipython3、setup-tools、pip等环境搭建详细总结
  14. 【bzoj1370】[Baltic2003]Gang团伙 并查集
  15. 用户注册加密操作,实现加密工具PasswordHelper
  16. [java多线程]高并发List与Map
  17. 算法设计与分析第四章习题解答与学习指导(第2版)屈婉婷 刘田 张立昂 王捍贫编著 清华大学出版社
  18. apdu 移动sim_SIM卡APDU指令【转】
  19. 搭建一个网站步骤 制作网页完整步骤
  20. 【前端】Vue+Element UI案例:通用后台管理系统-用户管理:Form表单填写、Dialog对话框弹出

热门文章

  1. matlab给图像加网格,matlab把图像进行网格化,或者是在图像中画网格
  2. Java把xx年xx月xx日(星期x) 上午xx点xx分转换Date类型
  3. [转载]我如何在计算机视觉顶级会议CVPR上发表论文?
  4. mysql 主动拿锁_主动锁模
  5. Vue编程的团队代码规范
  6. python错误解决TypeError: () must be callable
  7. 网络搜索先锋 v1.0 官方
  8. 致远a8-v5-6.0协同管理软件_Batteries for Mac(电池电量管理软件) v2.0
  9. 人为回环SLAM-Human-in-the-Loop SLAM
  10. C语言之tentative definition