選單

offset

RocketMQ消費進度管理淺析
科技

RocketMQ消費進度管理淺析

load()來載入消費進度,其原理就是根據約定拼接處檔案全路徑之後讀取相應檔案,然後序列化為OffsetSerializeWrapper物件:假設我們有個傳送簡訊的服務訂閱“SMS_prod”Topic,那麼形成的Json如下所示:注意of...