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

龙图腾网获悉平安国际智慧城市科技股份有限公司申请的专利基于Kafka的消息处理方法、装置、设备及存储介质获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN114546681B 。

龙图腾网通过国家知识产权局官网在2026-02-10发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202210159014.2，技术领域涉及：G06F9/54；该发明授权基于Kafka的消息处理方法、装置、设备及存储介质是由陈家龙设计研发完成，并于2022-02-21向国家知识产权局提交的专利申请。

本基于Kafka的消息处理方法、装置、设备及存储介质在说明书摘要公布了：本申请涉及消息队列技术领域，提供一种基于Kafka的消息处理方法、装置、设备及存储介质，该方法包括：当目标消息消费失败时，生成所述目标消息对应的延迟消息，所述延迟消息中包含所述目标消息的消息体内容；将所述延迟消息发送至预配置的目标Kafka延迟消息队列；当所述目标Kafka延迟消息队列中的所述延迟消息延迟到期时，提取所述延迟消息中的所述消息体内容，并根据所述消息体内容生成所述目标消息对应的重发消息；将所述重发消息发送至Kafka消息队列，以供消费端从所述Kafka消息队列中获得所述重发消息进行消费，实现了提高消息消费成功率。本申请还涉及区块链技术，Kafka消息队列可以存储在区块链节点中。

本发明授权基于Kafka的消息处理方法、装置、设备及存储介质在权利要求书中公布了：1.一种基于Kafka的消息处理方法，其特征在于，所述基于Kafka的消息处理方法包括： 当目标消息消费失败时，生成所述目标消息对应的延迟消息，所述延迟消息中包含所述目标消息的消息体内容；所述延迟信息包括所述目标消息的延迟等级、所述目标消息的已重发次数中至少一种； 将所述延迟消息发送至预配置的目标Kafka延迟消息队列； 当所述目标Kafka延迟消息队列中的所述延迟消息延迟到期时，提取所述延迟消息中的所述消息体内容，并根据所述消息体内容生成所述目标消息对应的重发消息； 将所述重发消息发送至Kafka消息队列，以供消费端从所述Kafka消息队列中获得所述重发消息进行消费； 所述将所述延迟消息发送至预配置的目标Kafka延迟消息队列，包括： 从预配置的多条Kafka延迟消息队列中，选取与所述目标消息对应的延迟信息匹配的Kafka延迟消息队列，确定为所述目标Kafka延迟消息队列； 将所述延迟消息发送至所述目标Kafka延迟消息队列。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人平安国际智慧城市科技股份有限公司，其通讯地址为：518000 广东省深圳市前海深港合作区妈湾兴海大道3048号前海自贸大厦1-34层；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

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