參考TCP協定滑動視窗的方式,實作業務端消息的确認;需要自己維護消費到的位置。
根據Kafka消息隊列的兩個特性:
1. 每個分區的消息隻能被一個消費者消費。
2. 每個分區中消息offset是有序遞增的。
每個分區在記憶體中維護一個相對應的滑動視窗,消息的offset為其序列号;隻有小于序列号SEQ1的所有消息都被正确處理,才更新消費位置,并把視窗往後滑動。
參考TCP協定滑動視窗的方式,實作業務端消息的确認;需要自己維護消費到的位置。
根據Kafka消息隊列的兩個特性:
1. 每個分區的消息隻能被一個消費者消費。
2. 每個分區中消息offset是有序遞增的。
每個分區在記憶體中維護一個相對應的滑動視窗,消息的offset為其序列号;隻有小于序列号SEQ1的所有消息都被正确處理,才更新消費位置,并把視窗往後滑動。