1.副本迁移脚本

kafka-reassign-partitions.sh工具来重新分布分区。该工具有三种使用模式：

（1）generate模式，给定需要重新分配的Topic，自动生成reassign plan（并不执行）【此模式在实际生产环境并不实用，基本没用过，因为分区的迁移需要考虑的因素太多，需要考虑负载均衡问题】；
（2）execute模式，根据指定的reassign plan重新分配Partition；
（3）verify模式，验证重新分配partition是否成功；

Status of partition reassignment:
Reassignment of partition [test,0] is still in progress【表示还在执行中】
Reassignment of partition [test,1] completed successfully【表示成功】
Reassignment of partition [test,2] is still in progress

#提交执行迁移任务
bin/kafka-reassign-partitions.sh --zookeeper 127.0.0.1:2181 --reassignment-json-file partitions-topic.json --execute#查看迁移任务执行进度
bin/kafka-reassign-partitions.sh --zookeeper 127.0.0.1:2181 --reassignment-json-file partitions-topic.json --verify

2.副本迁移任务提交流程解析

Kafka源码解析 - 副本迁移任务提交流程相关推荐

【kafka】Kafka 源码解析：Group 协调管理机制
1.概述转载:Kafka 源码解析:Group 协调管理机制在 Kafka 的设计中,消费者一般都有一个 group 的概念(当然,也存在不属于任何 group 的消费者),将多个消费者组织成一个 ...
kafka源码_十年资深架构师多年工作经验结晶：Kafka源码解析与实战
前言本篇系统介绍Kafka的实现原理和应用方法,并介绍Kafka的运维工具.客户端编程方法和第三方集成方式,深入浅出.图文并茂.分析透彻. 本篇将从初学者的角度出发,循序渐进地讲解Kafka内部的实 ...
Netty 源码解析系列-服务端启动流程解析
netty源码解析系列 Netty 源码解析系列-服务端启动流程解析 Netty 源码解析系列-客户端连接接入及读I/O解析五分钟就能看懂pipeline模型 -Netty 源码解析 1.服务端启动 ...
Zabbix 源码解析之监控项数据采集流程
一.概述监控项数据采集是一个监控工具最基本的功能,监控数据采集的准确.实时.有效是Zabbix其它监控功能正常运转的前提.因此,Zabbix运维人员有必要了解监控项数据采集流程,并有针对性的设计巡检 ...
FlinkSQL源码解析（三）执行流程
1.前言前面2部分主要是介绍以下2点: flink sql整体的执行流程大致为:sqlNode --> Operation --> RelNode --> 优化 --> ex ...
Spring源码解析(五)-Bean的实例化流程(上)
在前面已经完成了对需要实例化bean的收集并封装成BeanDefinition,并且将BeanPostProcess等组件进行了提前实例化.接下来就到了容器启动的最后一步,也是最复杂的一步-实例化be ...
从源码解析-结合Activity加载流程深入理解ActivityThrad的工作逻辑
ActivityThread源码解析前言类简称类简介一二三四五代理和桩的理解 ActivityThread ActivityThread.main AT.attach AMN.get ...
爆火的Java面试题-kafka源码解析与实战豆瓣
1 基础为什么 Java 中只有值传递? int 范围?float 范围? hashCode 与 equals,什么关系? String StringBuffer 和 StringBuilder 的 ...
【框架源码】Spring源码解析之BeanDefinition加载流程解析
观看本文之前,我们先思考一个问题,Spring是如何描述Bean对象的? Spring是根据BeanDefinition来创建Bean对象,BeanDefinition就是Spring中表示Bean定 ...

Kafka源码解析 - 副本迁移任务提交流程

1.副本迁移脚本

2.副本迁移任务提交流程解析

Kafka源码解析 - 副本迁移任务提交流程相关推荐

最新文章

热门文章