天天看点

简述kafka生产者ack确认机制

一、总结

  1. 该章节主要探讨造成数据丢失问题

    生产者ack确认机制(目的是要有多少个分区副本收到消息,生产者才认为该消息写入成功;acks参数对数据是否丢失起重要的作用)

    (1)ack = 0,就是表示生产者不会和broker确认消息是否写入成功。这就有可能造成服务器broker因出现问题,导致没有接收到生产者的消息,而生产者却无从得知。这也就造成数据的丢失。 --较低延迟和高吞吐量,但是以消息丢失的高风险为代价。

    (2)ack = 1,是表示,生产者是以broker集群leader分区副本接收到消息并向生产者发送成功响应的ack来代表消息写入成功。–只等待leader写完,不等待follower写完。这种机制,当leader向生产者发送响应后,follower同步消息之前,leader出现故障,会导致消息丢失。–比ack=0慢点,但是耐用。

    (3)ack = -1,是当设置ack值为all意味着所有同步副本都收到记录,生产者才会接收到broker服务器的响应。这种模式是最高级别的,也是最安全的,可以确保不止一个Broker接收到了消息. 该模式的延迟会很高.