rocketmq 的cluster模式下確保消息不丟失之消費進度維護

rocketmq 保證消息不丟失,如何作到,須要研究下如何維護消費進度的.java 會會致使重複消費. 本文不考慮broker宕機沒法啓動,熱備等狀況 git 首先最終根數據保持在每一個broker中的ConsumerOffsetManager類github * Consumer消費進度管理 * * @author shijia.wxr<vintage.wang@gmail.com> *

>>阅读原文<<