RocketMQ消息消费四：消费进度offset存储

概述 消息消费完成后，须要将消费进度存储起来，即前面提到的offset。广播模式下，同消费组的消费者相互独立，消费进度要单独存储；集群模式下，同一条消息只会被同一个消费组消费一次，消费进度会参与到负载均衡中，故消费进度是须要共享的。java 消费进度相关类 OffsetStore 为统一的消费进度接口，定义了操做入口web public interface OffsetStore { /*

>>阅读原文<<