摘要
本申请提供了一种kafka精确延迟控制方法、装置、设备和存储介质,所述方法包括:获取第一kafka集群的第一延迟主题分区中的目标延迟消息;一个kafka集群对应一个延迟主题,一个延迟主题包括多个根据不同延迟时间间隔划分的延迟主题分区;解析所述目标延迟消息的消息头,判断所述目标延迟消息是否到达延迟时间;若到达所述延迟时间,根据所述延迟时间和所述第一延迟主题分区,判断所述延迟时间是否为精确延迟时间;根据所述精确延迟时间的判断结果,发送所述目标延迟消息至第一kafka集群。
技术关键词
kafka集群
精确延迟控制
主题
消息
分区
延迟误差
贪心算法
计算机设备
模块
处理器
可读存储介质
列表
存储器
系统为您推荐了相关专利信息
数据分析方法
数据类型编码
多源异构数据
分区规则
数据更新频率
爆破施工方法
爆破孔
遗传算法求解
边坡台阶
遗传算法建立
分区
评估指标体系
节点
需求预测模型
资源管理方法