先说重复消费现象的成因,再说可选的解决方案。
一. Kafka 重复消费的产生原因生产端和消费端均有可以导致重复消费的场景。
1.1 生产过程产生重复消息生产者发出一条消息,Broker 正常存储该消息,但之后有可能因为各种因素未正常响应生产者(比如网络问题、Broker宕机等等)。
此时,若生产者不想冒消息丢失的风险,那它将只有一个选择:重试。
当 Broker 将该消息正常存储后,Kafka 中便有了两条重复的消息,进而引发消费端多次…。
如何利用cursor快速理解复杂代码工程?
如何看待黄奇帆称「中国房地产消费的居民负债占家庭收入比重达 137.9% ,需调整抑制消费政策」?
男医生在给年轻靓丽的女性检查时会是什么心态?
计算机基础在工作中,到底有多重要?
以前大力推广的沼气池,怎么现在越来越少了?
如何看待 Rust 的应用前景?
go为了编译速度减少了很多编译优化?为什么不能提供优化编译模式来提升运行效率?是太懒还是另有隐情?
Swift 和同时代的其他语言比起来怎么样?
Golang中有必要实现Async/Await吗?
58 同城被曝大规模裁员,比例或达 30%,具体情况如何?58 同城目前面临哪些问题?
电话:
座机:
邮箱:
地址: