【kafka】ack应答机制

标签：leader   cer   安全性   rod   需要   strong   去掉   alt   发送消息   

ack应答机制

有三个值：

• 0：producer不需要确认消息，直接发送消息给leader，有没有收到消息，producer不管；

  上图中去掉5、6步；速度块，安全性最低（当broker故障，会丢失数据）。

• 1：producer发送消息，确保leader写入成功，followers不管；上图中，去掉5步；

  （在follower同步成功之前leader故障，就会丢失数据）

• -1（all）：leader和followers全部确认发送到；上图即all机制；

  （如果follower同步完成后，leader还没发送ack给Producer的时候，出现了故障，这时候会重新选出一个leader，Producer因为没有收到ack，就会重新发送给新的leader，造成数据重复）

【kafka】ack应答机制

标签：leader   cer   安全性   rod   需要   strong   去掉   alt   发送消息   

原文地址：https://www.cnblogs.com/mussessein/p/12186593.html