RocketMQ消息消費四：消費進度offset存儲

概述 消息消費完成後，須要將消費進度存儲起來，即前面提到的offset。廣播模式下，同消費組的消費者相互獨立，消費進度要單獨存儲；集羣模式下，同一條消息只會被同一個消費組消費一次，消費進度會參與到負載均衡中，故消費進度是須要共享的。java 消費進度相關類 OffsetStore 爲統一的消費進度接口，定義了操做入口web public interface OffsetStore { /*

>>阅读原文<<