一种Kafka的分区方法、分区系统及相关装置

摘要

本申请提供一种Kafka的分区方法，包括：S1：获取实际总分区数、当前存活的消费者容器数以及每个存活的消费者容器对应的实际分区数；S2：确定平均应得分区数；S3：根据实际分区数和平均应得分区数确定分区差值；S4：从分区差值最大的第一消费者容器剥离一个分区，分配至分区差值小于0的第二消费者容器，并更新消费者容器对应的分区差值；S5：重复执行S4，直至任意两个消费者容器对应的实际分区数之差的绝对值小于等于1。本申请大大降低了分区所耗费的时间，提高了分区的效率，实现了动态分区，可以满足高实时性要求。本申请还提供一种Kafka的分区系统、一种计算机可读存储介质和一种分区服务器，具有上述有益效果。