天天看點

Kafka消息隊列實作業務端确認的方案

參考TCP協定滑動視窗的方式,實作業務端消息的确認;需要自己維護消費到的位置。

Kafka消息隊列實作業務端确認的方案

根據Kafka消息隊列的兩個特性:

1. 每個分區的消息隻能被一個消費者消費。

2. 每個分區中消息offset是有序遞增的。

每個分區在記憶體中維護一個相對應的滑動視窗,消息的offset為其序列号;隻有小于序列号SEQ1的所有消息都被正确處理,才更新消費位置,并把視窗往後滑動。