码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • kafka ack确认机制


    Kafka使用ACK(Acknowledgment)确认机制来确保消息在生产者和消费者之间的可靠传递。这个机制确保消息在被认为已成功发送或处理之前不会被丢失。Kafka的ACK确认机制有三个级别:

    1. acks=0: 这是最快速的确认级别,也是最不可靠的。生产者发送消息后不会等待任何确认,直接将消息添加到分区的副本中,并认为消息已成功发送。在这种模式下,如果发生故障或错误,生产者将不会知道,也不会重试发送消息。这种模式通常用于不太关心消息可靠性的场景。

    2. acks=1: 这是默认的确认级别,也称为“leader确认”。在这个级别下,生产者发送消息后会等待分区的领导者(leader)确认消息已成功写入到其本地日志。一旦领导者确认,生产者会认为消息已成功发送。这种模式下,如果领导者成功写入消息但在复制给其他副本时发生故障,消息可能会丢失。但在大多数情况下,消息可靠性已经得到保证。

    3. acks=all或acks=-1: 这是最严格的确认级别,也称为“全部确认”或“等待所有副本确认”。在这个级别下,生产者发送消息后会等待所有分区副本都确认消息已成功写入到它们的本地日志,然后才认为消息已成功发送。这确保了消息不会在任何情况下丢失,即使领导者发生故障,仍然可以从其他副本中获取。但这种确认级别可能会引入更多的延迟,因为需要等待所有副本确认。

    选择ACK确认级别取决于您的应用程序需求和对消息可靠性的要求。如果您需要最高级别的消息可靠性,可以选择acks=all。如果消息可靠性要求不太严格,可以选择acks=1或acks=0以提高性能。要注意,在acks=all模式下,如果Kafka集群的副本因某种原因无法满足确认要求,写入操作可能会失败,因此需要在选择确认级别时进行权衡。

  • 相关阅读:
    Reflect的作用,target,property,value,receiver代表啥
    FCN中制作自己的数据集并进行训练
    谈思生物医疗直播—可瑞生物CEO谢兴旺博士“TCR创新药的现状和展望”
    this.$nexttick settimeout promise
    玩以太坊链上项目的必备技能(类型-值类型-Solidity之旅二)
    腾讯云优惠券免费领取入口整理分享
    Java 多线程:基础
    使用C#编写一个读取和判断股票实时成交数据的小工具
    Redis (二)
    腾讯云服务器部署vue前端项目(Ubuntu+vue+nginx+nodejs+npm)
  • 原文地址:https://blog.csdn.net/u011095039/article/details/132969324
  • 最新文章
  • 攻防演习之三天拿下官网站群
    数据安全治理学习——前期安全规划和安全管理体系建设
    企业安全 | 企业内一次钓鱼演练准备过程
    内网渗透测试 | Kerberos协议及其部分攻击手法
    0day的产生 | 不懂代码的"代码审计"
    安装scrcpy-client模块av模块异常,环境问题解决方案
    leetcode hot100【LeetCode 279. 完全平方数】java实现
    OpenWrt下安装Mosquitto
    AnatoMask论文汇总
    【AI日记】24.11.01 LangChain、openai api和github copilot
  • 热门文章
  • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
    奉劝各位学弟学妹们,该打造你的技术影响力了!
    五年了,我在 CSDN 的两个一百万。
    Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
    面试官都震惊,你这网络基础可以啊!
    你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
    心情不好的时候,用 Python 画棵樱花树送给自己吧
    通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
    13 万字 C 语言从入门到精通保姆级教程2021 年版
    10行代码集2000张美女图,Python爬虫120例,再上征途
Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1
正则表达式工具 cron表达式工具 密码生成工具

京公网安备 11010502049817号