kafka精确延迟控制方法、装置、计算机设备和存储介质

AITNT
正文
推荐专利
kafka精确延迟控制方法、装置、计算机设备和存储介质
申请号:CN202410830061
申请日期:2024-06-25
公开号:CN118590448A
公开日期:2024-09-03
类型:发明专利
摘要
本申请提供了一种kafka精确延迟控制方法、装置、设备和存储介质,所述方法包括:获取第一kafka集群的第一延迟主题分区中的目标延迟消息;一个kafka集群对应一个延迟主题,一个延迟主题包括多个根据不同延迟时间间隔划分的延迟主题分区;解析所述目标延迟消息的消息头,判断所述目标延迟消息是否到达延迟时间;若到达所述延迟时间,根据所述延迟时间和所述第一延迟主题分区,判断所述延迟时间是否为精确延迟时间;根据所述精确延迟时间的判断结果,发送所述目标延迟消息至第一kafka集群。
技术关键词
kafka集群 精确延迟控制 主题 消息 分区 延迟误差 贪心算法 计算机设备 模块 处理器 可读存储介质 列表 存储器
系统为您推荐了相关专利信息
1
一种车联网中基于批量认证的恶意消息检测方法和系统
恶意消息 验证算法 批量 车辆 列表
2
一种基于机器学习的数据分析方法及系统
数据分析方法 数据类型编码 多源异构数据 分区规则 数据更新频率
3
一种安全爆破施工方法
爆破施工方法 爆破孔 遗传算法求解 边坡台阶 遗传算法建立
4
一种基于量子安全服务认证的对称量子安全加密通信方法
证书 终端 消息 加密通信方法 索引
5
5G移动边缘计算资源管理方法
分区 评估指标体系 节点 需求预测模型 资源管理方法
添加客服微信openai178,进AITNT官方交流群
驱动智慧未来:提供一站式AI转型解决方案
沪ICP备2023015588号