- 链接地址:https://yaohongxu.blog.csdn.net/article/details/124858826
- 链接标题:Kafka 是如何实现exactly once语义的?_kafka exactly once-CSDN博客
- 所属网站:yaohongxu.blog.csdn.net
- 被收藏次数:2166
文章浏览阅读1.7k次。一、消息语义概述在分布式系统中,构成系统的任何节点都是被定义为可以彼此独立失败的。比如在 Kafka中,broker可能会crash,在producer推送数据至topic的过程中也可能会遇到网络问题。根据producer处理此类故障所采取的提交策略类型,我们可以获得不同的语义:至少一次(at-least-once):消息不会丢失,但有可能被重复发送。如果producer收到来自Kafka broker的确认(ack)或者acks = all,则表示该消息已经写入到Kafka。但如果producer_kafka exactly once
版权声明:本文发布于特牛生活网 内容均来源于互联网 如有侵权联系删除