ack概述

kafka的ack机制,指的是producer的消息发送确认机制,在不同的场景可以灵活的选择ack机制来配合业务,不同的ack设置对kafka集群的吞吐量和消息可靠性也会有影响。

ack有三个值可以选择 0,1,-1(all),下面分别介绍这三种情况的发送确认机制是怎样的。

  • ack = 0,就是kafka生产端发送消息之后,不管broker的副本有没有成功收到消息,在producer端都会认为是发送成功了,这种情况提供了最小的延迟,和最弱的持久性,如果在发送途中leader异常,就会造成数据丢失。

  • ack = 1,是kafka默认的消息发送确认机制,此机制是在producer发送数据成功,并且leader接收成功并确认后就算消息发送成功,但是这种情况如果leader接收成功了,但是follwer未同步时leader异常,就会造成上位的follwer丢失数据,提供了较好的持久性和较低的延迟性。

  • ack =-1,也可以设置成all,此机制是producer发送成功数据,并且leader接收成功,并且follwer也同步成功之后,producer才会发送下一条数据。

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐