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