当前位置: 首页 > news >正文

kafka 的ack机制

ACK 的三个可选配置值

在生产者配置中,通过 acks 参数进行设置(通常是 acks,而不是 ack)。

1. acks = 0

  • 含义:“发后即忘”。生产者发送消息后,完全不需要等待来自 Kafka 服务器的任何确认,就立即认为消息发送成功。

  • 优点:

    • 延迟最低:因为没有等待,吞吐量最高。

  • 缺点:

    • 可靠性最差:如果网络抖动、Broker 宕机等,消息可能丢失,生产者却无从知晓。

  • 适用场景:对可靠性要求极低,允许少量消息丢失,但追求极高吞吐量的场景,例如日志收集。

2. acks = 1

  • 含义:默认值。生产者发送消息后,只需要等待分区的 领导者副本 将消息写入其本地日志,就可以认为发送成功。

  • 优点:

    • 在可靠性、延迟和吞吐量之间取得了较好的平衡。

  • 缺点:

    • 仍有丢失风险:如果领导者副本刚写入消息就突然宕机,且消息还未被其他追随者副本同步,那么新的领导者会被选举出来,但它不包含这条消息,导致消息丢失。

  • 适用场景:大多数常规业务场景,对可靠性有一定要求,但可以接受在极端情况下的少量丢失。

3. acks = all (也可以写作 acks = -1)

  • 含义:最严格。生产者发送消息后,需要等待分区的 所有同步中的副本(ISR) 都将消息成功写入其本地日志,才会收到成功确认。

  • 优点:

    • 可靠性最高:只要至少有一个同步副本存活,消息就不会丢失。

  • 缺点:

    • 延迟最高:因为需要等待所有副本的确认,网络往返时间更长。

    • 吞吐量最低。

  • 额外配置:为了确保不陷入无限等待,通常需要配合 min.insync.replicas 参数(通常在 Broker 或主题级别配置)使用。

    • min.insync.replicas=2 表示至少需要 2个 ISR 副本确认,生产者才认为成功。如果 ISR 集合中的副本数少于这个值,生产者会抛出一个异常(NotEnoughReplicasException)。

http://www.jsqmd.com/news/50484/

相关文章:

  • 窗体关闭事件
  • AcWing 788:逆序对的数量 ← 树状数组 + 离散化(数组 + sort + STL map)
  • AI 数据分析如何保障准确性?Aloudata Agent 构建可信数据基础
  • MWD脉冲器电路关键技术与挑战
  • 2025年广东早恋教育机构权威推荐榜单:素质教育/打架/厌学源头机构精选
  • tignerVNC
  • 麒麟系统V10SP1更新到指定内核方法
  • 深入解析:英集芯 IP5326 集成Type-C协议的2.4A充放电移动电源SOC
  • 视频汇聚平台EasyCVR打造阳光药房远程可视化智慧监管体系
  • 2025厦门口碑好的留学中介有哪些
  • 2025年河北大口径胶管权威推荐榜单:河北大口径抽沙胶管/河北大口径吸沙胶管/河北喷砂吸排法兰胶管源头厂家精选
  • 2025广州权威的留学机构排名榜
  • DeerFlow源码分析
  • 2025北京留学机构前十名有哪些
  • 2025年北京回收二手红木家具公司权威推荐榜单:回收红木家具高价/回收阔叶黄檀家具/回收缅甸花梨家具源头公司精选
  • 2025澳大利亚研究生留学中介哪个好
  • 视频融合平台EasyCVR助力城市渣土车管理,打造智能联网监控方案
  • 服务器远程连接不上怎么回事?怎么解决?
  • 多位
  • CF1458C Latin Square
  • 2025年湖北阴囊湿疹怎么治疗护理权威推荐榜单:湖北附睾结核怎么治疗/湖北脓尿怎么治疗/湖北肾盂肾炎怎么治疗综合医院特色门诊精选
  • 2025广州权威的留学机构排名前十
  • 2025北京留学机构一览表最新
  • 这些奇怪的JavaScript隐式转换你一定遇到过!
  • 2025澳大利亚留学中介排行
  • 大象《Thinking in Projects》读书笔记3
  • 2025年高层建筑物平移源头厂家权威推荐榜单:房屋整体平移/建筑物平移/别墅平移源头厂家精选
  • 三分钟带你了解什么是 Headless UI (含demo)
  • PDF超级助手软件下载安装教程_免费PDF编辑工具使用指南
  • Vue3快速笔记