2024年8月22日消息,天眼查知识产权信息显示,福建天泉教育科技有限公司申请一项名为“一种基于kafka实现消息延时处理的方法与服务端“,公开号CN202410536552.8,申请日期为2024年4月。
专利摘要显示,本发明公开了一种基于kafka实现消息延时处理的方法与服务端,kafka消息中间件根据预设的不同延迟消费时长,在消息中间件的延迟消费主题中进行分片划分,并为每一所述分片创建对应的消费者;接收程序消息,根据所述程序消息中选择的时长,将所述程序消息发送到延迟消费主题的对应分片中,由所述分片所对应的所述消费者进行顺序消费;在kafka消息中间件中根据预定的延时消费时长,划分不同的分片并创建对应的消费者,可以确保每个分区内的消息都有相同的延迟时长,从而避免了消费者可能会被迫等待最长延迟的消息才能消费后面的消息,造成不必要延迟的问题,提高消息消费效率。