第六节 Kafka的三种语义以及实现代码

亮子 2023-08-02 08:09:15 17076 0 0 0

1、至多一次

图片alt

在通过poll函数读取消息后,无论后面消息处理是否成功,消息都会被删除,这样就是实现了消息的至多一次。

2、至少一次

1)、批量确认

图片alt

这样先处理数据,再提交消息确认,这样消息在处理过程中出现异常,则由于没有确认消息,而导致消息没有删除,这样还可以再次消息。

3)、逐条确认

图片alt

3、精准一次

待实现