标签：producer ack ISR 确认 broker kafka follower leader

ack（acknowledgemen 确认收到）

A1 目的

为了保证producer发送的数据能可靠的发送到指定的topic。

A2 过程

topic的每个partition收到producer发送的数据后，都需向producer发送ack，如果producer收到ack，就会进行下一轮的发送，否则重新发送。

A3 穿插

ISR机制：

• Leader维护了一个动态的in-sync replica set (ISR)，意为和leader保持同步的follower集合。follower长时间不同步，被踢出ISR ，该时间阈值由replica.lag.time.max.ms参数设定。Leader发生故障之后，就会从ISR中选举新的leader。

A4 ack应答机制：

ack级别：

• 0：producer不等待broker的ack，最低延迟，broker一收到还没写入磁盘就返回，当broker故障时易丢失数据。
• 1：producer等待broker的ack，partition的leader落盘成功后返回ack，如果在follower同步成功之前leader故障，那么将会丢失数据。
• -1（all）：producer等待broker的ack，partition的leader和follower全部落盘成功后才返回ack。但是如果在follower同步完成后，broker发送ack之前，leader发生故障，那么会造成数据重复。

标签：producer,ack,ISR,确认,broker,kafka,follower,leader
来源： https://blog.csdn.net/Jin_Lemon/article/details/115337156

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。