摘要
本申请提供了一种重平衡方法、装置、设备、介质及产品,在创建第一主题的情况下,若第一主题的预设分区数大于预设大分区阈值,则将第一主题的第一分区进行拆分得到多个第二分区,预设分区数用于确定第一主题的第一分区的分区数量,一个第一分区对应多个第二分区,第二分区的分区数量大于第一分区的分区数量;一个消费组消费至少一个第二分区对应的消息;在第一消费组接收到是否进行重平衡请求的情况下,获取第一消费组负责的所有第三分区在预设时间内的消费情况,第二分区包括第三分区;根据消费情况,确定所有第三分区中参与重平衡的目标分区;对第一消费组和目标分区进行重平衡。本申请实施例能够提高kafka系统的消息处理的效率。
技术关键词
分区
主题
平衡方法
计算机程序指令
kafka集群
计算机程序产品
消息
选举算法
客户端
电子设备
可读存储介质
处理器
平衡装置
逻辑
模块
参数
标识
节点
系统为您推荐了相关专利信息
智能决策系统
血管分割
循证医学证据
影像
狭窄识别
多元回归模型
半导体工艺配方
数值
计算机程序指令
良率
脉宽调制模块
噪声消除模块
长距离通信
芯片架构
多组并联