买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉福建天泉教育科技有限公司申请的专利一种基于kafka实现消息延时处理的方法与装置获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN118502984B 。

龙图腾网通过国家知识产权局官网在2026-01-06发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202410536552.8，技术领域涉及：G06F9/54；该发明授权一种基于kafka实现消息延时处理的方法与装置是由刘德建;谢在晶;宋全程;薛天水;陈宏设计研发完成，并于2024-04-30向国家知识产权局提交的专利申请。

本一种基于kafka实现消息延时处理的方法与装置在说明书摘要公布了：本发明公开了一种基于kafka实现消息延时处理的方法与装置，kafka消息中间件根据预设的不同延迟消费时长，在消息中间件的延迟消费主题中进行分片划分，并为每一所述分片创建对应的消费者；接收程序消息，根据所述程序消息中选择的时长，将所述程序消息发送到延迟消费主题的对应分片中，由所述分片所对应的所述消费者进行顺序消费；在kafka消息中间件中根据预定的延时消费时长，划分不同的分片并创建对应的消费者，可以确保每个分区内的消息都有相同的延迟时长，从而避免了消费者可能会被迫等待最长延迟的消息才能消费后面的消息，造成不必要延迟的问题，提高消息消费效率。

本发明授权一种基于kafka实现消息延时处理的方法与装置在权利要求书中公布了：1.一种基于kafka实现消息延时处理的方法，其特征在于，包括步骤： S1、kafka消息中间件根据预设的不同延迟消费时长，在消息中间件的延迟消费主题中进行分片划分，并为每一所述分片创建对应的消费者； S2、接收程序消息，根据所述程序消息中选择的时长，将所述程序消息发送到延迟消费主题的对应分片中，由所述分片所对应的所述消费者进行顺序消费； 所述程序消息中包括消费时间，所述消费时间根据消息发送的时间以及延迟时长确定； 所述顺序消费包括步骤： S21、所述消费者从所述分片中批量拉取所述程序消息，并启动多个消费线程并发进行消息处理； S22、所述消费线程针对所述程序消息，判断当前时间是否达到所述程序消息中所述消费时间，若是则消费消息，否则根据所述消费时间进行休眠，在休眠结束后消费消息； 还包括步骤： S23、消费者在当前批次消息消费完成后，提交偏移量，更新所述消费者在所述分片中当前消费到的位置； 步骤S1具体为： kafka消息中间件基于预设的自定义分区器，根据预设的不同延迟消费时长，在消息中间件的延迟消费主题中进行分片划分，并为每一所述分片创建对应的消费者； 所述自定义分区器继承自org.apache.kafka.clients.producer.Partitioner接口； 所述org.apache.kafka.clients.producer.Partitioner接口中的partition方法预先重写为根据消息的延迟消费时长来计算出消息应归属的分片。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人福建天泉教育科技有限公司，其通讯地址为：350212 福建省福州市长乐区湖南镇大鹤村(福建天棣动漫科技有限公司)；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。