热门标签
热门文章
- 1【SD插件】轻松一键修复脸部变形-After Detailer_sd 生成图 人脸不全
- 2【node:19212】 解决 Node.js 报错 “将文件视为 CommonJS 模块“
- 3十九、FPGrowth算法介绍_fpgrowth排序
- 4Git - 在PyCharm/Idea中集成使用Git
- 5PX4位置控制offboard模式说明_px4offboard
- 6Flink动态更新维表_lookup.partial-cache.expire-after-write
- 7Verilog 不可综合部分
- 8论文解读《Text Compression-aided Transformer Encoding》_隐式文本
- 9PMP重考流程与费用_pmp重考费用是多少
- 10Window 安装Hive_请截图显示hive的安装结果
当前位置: article > 正文
【Kafka】【二十六】Kafka优化之实现延时队列_kafka延迟30分钟消费数据
作者：花生_TL007 | 2024-04-25 08:39:25
赞
踩
kafka延迟30分钟消费数据
Kafka优化之实现延时队列
应⽤场景
订单创建后，超过30分钟没有⽀付，则需要取消订单，这种场景可以通过延时队列来实现
具体方案
- kafka中创建相应的主题
- 消费者消费该主题的消息（轮询）
- 消费者消费消息时判断消息的创建时间和当前时间是否超过30分钟（前提是订单没⽀付）
- 如果是：去数据库中修改订单状态为已取消
- 如果否：记录当前消息的offset，并不再继续消费之后的消息。等待1分钟后，再次向kafka拉取该offset及之后的消息，继续进⾏判断，以此反复。
推荐阅读
相关标签
