尧图网站建设 尧图网络
  • 首页
  • 关于我们
  • 服务项目
  • 案例展示
  • 建站流程
  • 资讯中心
  • 联系我们
首页/资讯中心/详情

kafka 的ack机制

kafka 的ack机制
📅 发布时间:2026/6/20 18:10:46

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)。

相关新闻

  • AcWing 788:逆序对的数量 ← 树状数组 + 离散化(数组 + sort + STL map)
  • 2025广州权威的留学机构排名榜
  • 2025广州权威的留学机构排名前十

最新新闻

  • 天河区大型搬家公司优选 珠江新城体育西全覆盖服务 - 从来都是英雄出少年
  • 2026年6月最新爱彼中国官方售后服务热线网点及客服电话地址 - 亨得利官方服务中心
  • 论文AI写作用什么好?4款工具不同场景不同需求推荐 - 掌桥科研-AI论文写作
  • GDB基础命令
  • 2026上海翡翠回收避坑指南|看懂行情价,拒绝虚高报价套路 - 奢侈品交易观察员
  • ahk2_lib架构解密:构建企业级AutoHotkey V2原生扩展生态

日新闻

  • 信任的进化:技术实现详解——如何用JavaScript构建博弈论模拟器
  • Terrakube自定义工作流:如何集成OPA、Infracost等工具扩展IaC能力
  • grunt-concurrent快速入门:5分钟学会并行运行Grunt任务

周新闻

  • 3步解锁iOS设备:applera1n激活锁绕过完全指南
  • 39 2026 人工智能证书终极盘点,普通人选 AI 证书可以从这些方向入手
  • Redis 暴露公网有多危险?从端口检查到补救步骤

月新闻

  • 【总结】入门篇:50句话让你记住架构核心概念
  • WeChatMsg技术方案解析:实现Mac微信数据自主管理的完整解决方案
  • WeChatMsg:革新性微信数据备份方案,打造你的专属数字记忆库

关于尧图

  • 公司简介
  • 团队介绍
  • 企业文化
  • 荣誉资质

服务项目

  • 定制开发
  • 电商建站
  • UI 设计
  • 运维服务

快速链接

  • 案例展示
  • 建站流程
  • 常见问题
  • 资讯中心

联系方式

  • 📍北京市朝阳区互联网产业园 A 座 10 层
  • 📞400-888-8888
  • ✉️contact@rkmt.cn
  • 🕐周一至周日 9:00-21:00

© 2024 北京尧图网络科技有限公司 版权所有 | 京 ICP 备 XXXXXXXX 号