当前位置： 首页 > news >正文

kafka实现延迟消息

news 2025/9/10 7:49:36

背景

我们知道消息中间件mq是支持延迟消息的发送功能的，但是kafka不支持这种直接的用法，所以我们需要独立实现这个功能，以下是在kafka中实现消息延时投递功能的一种方案

kafka实现延时消息

主要的思路是增加一个检测服务，这个检测服务会每分钟定时从延时队列中获取消息，然后判断这些延迟消息是否到期，如果到期，那么就把这条消息发送到正常的队列中，如果还没到期，继续放到延时队列里面,这样就可以实现延时队列的功能了.
在这里插入图片描述

http://www.lryc.cn/news/270145.html

相关文章：

  • python+django高校教材共享管理系统PyCharm 项目
  • 三子棋（c语言）
  • 09.kubernetes 部署calico / flannel网络插件
  • 【DevOps 工具链】搭建 项目管理软件 禅道
  • ES6的默认参数和rest参数
  • 深入理解WPF MVVM：探索数据绑定与命令的优雅之道
  • ssrf之gopher协议的使用和配置，以及需要注意的细节
  • SVN下载安装（服务器与客户端）
  • SpringIOC之ApplicationObjectSupport
  • 香橙派 ubuntu实现打通内网，外网双网络,有线和无线双网卡
  • Spring Boot简单多线程定时任务实现 | @Async | @Scheduled
  • sklearn学习的一个例子用pycharm jupyter
  • JVM的生命周期
  • ElasticSearch--基本操作
  • 大数据应用发展史：从搜索引擎时代到机器学习时代
  • java基础之String的不可变性
  • 【JS】Promise详解
  • 原生微信小程序如何动态配置主题颜色及如何调用子组件的方法
  • Java关键字（1）
  • 【机器学习合集】深度生成模型 -＞（个人学习记录笔记）
  • Java将PDF转换为文本
  • Linux 运维工具之1Panel
  • 深入了解小红书笔记详情API：为内容创新提供动力
  • Animate 2024(Adobe an2024)
  • 尽量避免删改List
  • 【Linux操作系统】探秘Linux奥秘：用户、组、密码及权限管理的解密与实战
  • 计算机组成原理复习4
  • AutoSAR（基础入门篇）3.3-Autosar中RTE的数据一致性与Interface接口
  • 超维空间S2无人机使用说明书——52、初级版——使用PID算法进行基于yolo的目标跟踪
  • ＜JavaEE＞ TCP 的通信机制（一） -- 确认应答 和 超时重传