背景
我们知道消息中间件mq是支持延迟消息的发送功能的,但是kafka不支持这种直接的用法,所以我们需要独立实现这个功能,以下是在kafka中实现消息延时投递功能的一种方案文章来源:https://www.toymoban.com/news/detail-858422.html
kafka实现延时消息
主要的思路是增加一个检测服务,这个检测服务会每分钟定时从延时队列中获取消息,然后判断这些延迟消息是否到期,如果到期,那么就把这条消息发送到正常的队列中,如果还没到期,继续放到延时队列里面,这样就可以实现延时队列的功能了.
文章来源地址https://www.toymoban.com/news/detail-858422.html
到了这里,关于kafka实现延迟消息的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!