当前位置: 首页 > 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.rkmt.cn/news/60350.html

相关文章:

  • AcWing 788:逆序对的数量 ← 树状数组 + 离散化(数组 + sort + STL map)
  • 2025广州权威的留学机构排名榜
  • 2025广州权威的留学机构排名前十
  • Vue3快速笔记
  • 详细介绍:技术实践:在基于 RISC-V 的 ESP32 上运行 MQTT over QUIC
  • 2025广州有哪些办理出国留学机构
  • 2025北京留学中介机构名单
  • odoo12 跟踪所有的模型调用的onchange 方法
  • 对于高增量数据库的解决方案记录(暂时修改)
  • MySQL权限管理的坑你踩了没有?
  • 2025 年 11 月冷却塔厂家权威推荐榜:闭式冷却塔、方形冷却塔、工业冷却塔、全钢冷却塔、凉水塔、圆形冷却塔、玻璃钢冷却塔、防腐冷却塔、冷却水塔,高效散热与持久耐用的专业之选
  • 2025北京留学中介哪些机构好一点
  • k8s chain
  • 不丢帧、低延迟!图像采集卡的 5 步工作原理,看懂就是专家
  • 2025年服装整烫专用设备定做厂家权威推荐榜单:服装小型整烫设备/服装隧道整烫设备/仙桃服装整烫设备源头厂家精选
  • Spring Data JPA 最佳实践【1/2】:实体设计指南
  • 2025年11月呼叫中心系统品牌推荐评测报告:从稳定性到AI能力的解决方案剖析
  • 2025广州最大的留学中介是哪家
  • 2025北京申请留学机构哪家好
  • QQueue队列
  • 2025年11月数据标注平台推荐评测报告:从安全部署到智能辅助解决方案剖析
  • 2025年11月北京会计师事务所推荐:权威榜单与选择指南
  • 2025年远程高能点火器实力厂家权威推荐榜单:遥控高能点火器/防爆高能点火器/便携式高能点火器源头厂家精选
  • php Http请求 GET方式
  • plt.show()什么时候不用写?什么时候必须写?
  • Pyplot vs Seaborn 功能实现对比(直方图+箱线图) Pyplot → Seaborn 快速迁移指南
  • 2025年最新评价高的板材货架源头厂家找哪家,工业重型货架/手摇式板材货架/线棒流利货架/移动流利货架/重型滚轮式流利货架厂商推荐排行
  • AI元人文:构建价值共生的协契未来
  • 2025年11月上海审计事务所推荐榜单:主流机构对比与选择指南
  • 2025年11月上海审计事务所口碑推荐:用户评价与市场报告深度解析