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

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