天天看点

Kafka消息队列实现业务端确认的方案

参考TCP协议滑动窗口的方式,实现业务端消息的确认;需要自己维护消费到的位置。

Kafka消息队列实现业务端确认的方案

根据Kafka消息队列的两个特性:

1. 每个分区的消息只能被一个消费者消费。

2. 每个分区中消息offset是有序递增的。

每个分区在内存中维护一个相对应的滑动窗口,消息的offset为其序列号;只有小于序列号SEQ1的所有消息都被正确处理,才更新消费位置,并把窗口往后滑动。