5.rocketmq源代码学习--客户端消息消费(消息拉取)

1、获取消费进度 rocketmq有两种消费模式: 广播模式—同一个消费者ID对应的多个消费者,将消息各消费一遍 集群模式–同一个消费者ID对应的多个消费者,共同消费一份消息java 广播模式 对应LocalFileOffsetStore,从本地获取消费进度web public final static String LocalOffsetStoreDir = System.getProperty
相关文章
相关标签/搜索