rocketmq 的cluster模式下确保消息不丢失之消费进度维护

rocketmq 保证消息不丢失,如何作到,须要研究下如何维护消费进度的.java 会会致使重复消费. 本文不考虑broker宕机没法启动,热备等状况 git 首先最终根数据保持在每一个broker中的ConsumerOffsetManager类github * Consumer消费进度管理 * * @author shijia.wxr<vintage.wang@gmail.com> *

>>阅读原文<<