RocketMQ源碼分析----Consumer消費進度相關

在Consumer消費的時候總有幾個疑問： 消費完成後，這個消費進度存在哪裏 消費完成後，還沒保存消費進度就掛了，會不會導致重複消費 Consumer 消費進度保存 消費完成後，會返回一個ConsumeConcurrentlyStatus.CONSUME_SUCCESS告訴MQ消費成功，以MessageListener的consumeMessage爲入口分析。 消費的時候，是以ConsumeReq

>>阅读原文<<