先说重复消费现象的成因,再说可选的解决方案。
一. Kafka 重复消费的产生原因生产端和消费端均有可以导致重复消费的场景。
1.1 生产过程产生重复消息生产者发出一条消息,Broker 正常存储该消息,但之后有可能因为各种因素未正常响应生产者(比如网络问题、Broker宕机等等)。
此时,若生产者不想冒消息丢失的风险,那它将只有一个选择:重试。
当 Broker 将该消息正常存储后,Kafka 中便有了两条重复的消息,进而引发消费端多次…。
代码:
为什么国外网站总喜欢弹出cookie访问权限弹窗,国内网站却没有,这么做有什么意义?
我国的军工能力可以实现一天5000枚火箭弹连着炸三个月吗?
为什么都说武器越怪,死的越快?
能够自己一个人创业的全栈web码农fullstack developer要会哪些技术?
异性同办公室久了会不会日久生情?
为什么盗版音乐已经被严格限制了,而中国音乐却还是没有发展起来?
据说go和c#的开发者都说自己比较节省内存,你们认为呢?
PHP现在真的已经过时了吗?
公司准备换系统有什么好用的ERP系统推荐嘛?
吃爽了是怎样一种体验?
在所有动物肉中,哪一种味道最好?
Golang vs Rust vs Dlang 哪个更有前途,哪位大牛这 3 门语言都用过?
超级喜欢穿短裙正常吗?
系统太稳定了甲方觉得我们没有工作量,怎么收运维费?
万兆的网络速度有多大意义?
男朋友因为打游戏骗我去睡觉被我识破,然后我提了分手,他同意了,问问男孩子们他怎么想的?
你身边身材最好的女生是什么样?
如何评价李健?
如何评价首个女性友好的编程语言HerCode?
做一个中国的微软到底有多难?
那你说什么样的是美女?
这种情况如何提高打字速度?
Node.js是谁发明的?
蜂鸟音乐指控邓紫棋侵权,要求 48 小时内下架重录歌曲,邓紫棋回应「不会下架」,这一指控合理吗?
以色列为什么突然敢打伊朗了?不怕被报复?
为什么说天下法术尽出江西?
微信服务器会保留聊天记录吗,会保存多久?
为什么很多司机不办 ETC?
Caddy 和 Nginx 比有哪些优点和缺点?