Kafka数据重复发送3次的问题
发布日期：2021-05-06 15:30:09
浏览次数：14
分类：精选文章
本文共 234 字，大约阅读时间需要 1 分钟。
在项目中，当用户提交订单时，采用Kafka将消息传递给Disruptor进行处理。由于处理新订单可能需要一定时间，主线程在将消息发布到Kafka后，设置了10秒的睡眠时间。然而，这段时间超过了Kafka的等待超时阈值，导致系统重新尝试发送消息，最终导致消息重复发送了三次。
分析发现，问题的根源在于主线程在消息发布后进行了长时间睡眠，超出了Kafka的可接受时间范围，触发了重试机制。为了避免这种情况，建议将睡眠时间调整为2秒，以确保符合Kafka的消息处理机制要求。
发表评论
最新留言
逛到本站，mark一下
[***.202.152.39]2025年04月12日 15时31分33秒
关于作者
喝酒易醉，品茶养心，人生如梦，品茶悟道，何以解忧？唯有杜康！
-- 愿君每日到此一游！
推荐文章
（数据科学学习手札40）tensorflow实现LSTM时间序列预测
2019-03-06
[整理] 哪些集合类是线程安全的？(Java)
2019-03-06
[整理] UML的各种图总结
2019-03-06
8 个警示和学习的 5 个阶段
2019-03-06
c# 图片带水纹波动
2019-03-06
H5 贪吃蛇源码
2019-03-06
c# 判断3个数是否连续最优式子
2019-03-06
从零开始学安全(十六)● Linux vim命令
2019-03-06
从零开始学安全(三十四)●百度杯 ctf比赛 九月场 sqli
2019-03-06
3389连接痕迹清除
2019-03-06
发生系统错误 6118
2019-03-06
c# API接受图片文件以文件格式上传图片
2019-03-06
阿里巴巴Json工具-Fastjson教程
2019-03-06
Spring Cloud Gateway - 快速开始
2019-03-06
Spring Security 实战干货：理解AuthenticationManager
2019-03-06
Java对象转JSON时如何动态的增删改查属性
2019-03-06
Python 面向对象进阶
2019-03-06
Linux常用统计命令之wc
2019-03-06
Git安装及使用以及连接GitHub方法详解
2019-03-06
白红宇的个人博客 - 记录点点滴滴的事 - 您是第 459549877 位访客