kafka生产数据时的应答机制(ACK)

ACK = 0：生产者发送完数据，不用考虑数据是否已到达kafka服务器，然后紧接着就发下一条数据，这样，效率会非常高。但是存在一个问题：数据的丢失可能性比较大。

ACK = 1：生产者发送数据，是需要等待leader的应答，如果应答完成，才能发送下一条message，是不关心follower是否pull完成，是否接收成功的。这样，虽说性能会慢些，但是数据会比较安全。可但是，在leader保存完数据后，突然leader所在的broker down掉了，此时的follower还没来得及从leader那儿pull数据，那么这个数据就会丢失。

ACK = -1：可以理解为最耗时的选项。当生产者发送数据后，需要等待所有的副本的应答，包括leader+follower，这种方式是最安全的，但同时也是性能最差的。

总结简化这三种情况：

ACK = 0：只发一次数据，不管leader是否接收成功
ACK = 1：只要等待leader接收完成即可（如果没有配置ack机制，则默认为1）
ACK = -1：需要等待leader将消息同步给所有的follower即可

(备注：当follower从leader那里pull数据后，会写入到本地的分段日志log中，同时也会返回给leader一个ACK标志)

有帮到你的点赞、收藏一下吧

需要更多教程，微信扫码即可

kafka生产数据时的应答机制(ACK)相关推荐

Kafka 生产者数据安全（ACK机制，ACK时机，ACK应答机制，故障处理，Exactly Once）
目录生产者数据安全一.数据分区图解分区原因分区原则二.数据可靠性保证 ACK机制 ACK时机 ACK应答机制故障处理 Exactly Once 语义生产者数据安全一.数据分区图解 ...
Kafka Ack应答机制理解
背景最近李哥做了kafka的调研,我看了他做的kafka与rabbitmq的对比与性能分析,打算深入了解一下kafka的ack应答机制 1.kafka基础大家可自行学习 2.这里我直接分析下ack应 ...
CAN总线-ACK应答机制分析
1:应答场定义应答场长度为 2 个位,包含应答间隙(ACK SLOT)和应答界定符(ACK DELIMITER).在应答场里,发送站发送两个"隐性"位.当接收器正确地接收到有效的 ...
TCP协议可靠性保证（确认应答机制，超时重传机制，流量控制，拥塞窗口）
上一次我们知道了TCP协议通过连接管理机制保证可靠性,今天我们继续来看一看TCP协议中其他几种保证可靠性的方法. · 确认应答机制 · 超时重传机制 · 流量控制 · 拥塞窗口确认应答机制 ...
以太网 TCP协议交互过程中出现丢包时的解决机制，超时重传、快速重传、SACK与DSACK
2.7.3 以太网 TCP协议(TCP交互过程中出现丢包时的解决机制-列举部分) 参考:CSDN_TCP的重传机制_博主.Pr Young,对描述进行了整理与结合个人的理解进行编写. 一.超时重传机制 ...
KafKa - 分区副本ISR选举机制
一.KafKa分区副本ISR选举机制 kafka 中每一个主题又进一步划分成若干个分区.副本的概念实际上是在分区层级下定义的,每个分区配置有多若干个副本. 所谓的副本,本质上就是一个只能追加写消息的提 ...
Kafka工作原理-数据写入、ACK、查询、消费原理
为什么需要消息队列周末无聊刷着手机,某宝网APP突然蹦出来一条消息"为了回馈老客户,女朋友买一送一,活动仅限今天!".买一送一还有这种好事,那我可不能错过!忍不住立马点了去.于是 ...
确认应答机制超时重传机制序列号延迟应答捎带应答
序列号一.什么是序列号? TCP会对每个字节的数据都进行编号,数据的编号就是数据的序列号,每个字节都有自己独一无二的编号,故序列号具有唯一性二.序列号的作用? 接收端为了区别重复的报文段(报文段也 ...
RabbitMQ手动应答机制-案例代码梳理
目录消息应答 1.概念 2.自动应答 3.手动应答 4.手动批量应答(Multiple) 5.消息自动重新入队 6.手动应答代码实现 7.源码地址消息应答参考代码:https://gitee.c ...

kafka生产数据时的应答机制(ACK)

总结简化这三种情况：

kafka生产数据时的应答机制(ACK)相关推荐

最新文章

热门文章