kafkaack应答机制

Posted 2021-03-16 mussessein

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，造成数据重复）