基于Kafka集群的分区迁移方法和装置

授权

摘要

本申请实施例提供了一种基于Kafka集群的分区迁移方法，所述方法包括：获取各个节点服务器中包含的磁盘与分区的对应关系以及获取各个磁盘中包含的所有分区的消息写入速率；遍历所有的节点服务器，并在遍历过程中找到不满足预设的第一分区策略的第一节点服务器时，从所述第一节点服务器中选择不满足预设的第二分区策略的第一磁盘，并从第一磁盘中选择预设的主题下的一个分区执行第一分区迁移操作；在执行第一分区迁移操作后，判断述第一节点服务器是否满足第一分区策略；若第一节点服务不满足所述第一分区策略，则重复执行上述步骤，直至第一节点服务器满足所述第一分区策略为止。本申请可以提高数据分发的吞吐效率。

基本信息

专利标题：

基于Kafka集群的分区迁移方法和装置

专利标题（英）：

暂无

公开（公告）号：

CN112269661A

申请号：

CN202011190878.8

公开（公告）日：

2021-01-26

申请日：

2020-10-30

授权号：

CN112269661B

授权日：

2022-04-15

发明人：

张辰安付航郑志升

申请人：

上海哔哩哔哩科技有限公司

申请人地址：

上海市杨浦区政立路485号国正中心3号楼

代理机构：

北京英特普罗知识产权代理有限公司

代理人：

邓小玲

优先权：

CN202011190878.8

主分类号：

G06F9/50

IPC分类号：

G06F9/50