RocketMQ源码分析----Consumer消费进度相关

在Consumer消费的时候总有几个疑问: 消费完成后,这个消费进度存在哪里 消费完成后,还没保存消费进度就挂了,会不会导致重复消费 Consumer 消费进度保存 消费完成后,会返回一个ConsumeConcurrentlyStatus.CONSUME_SUCCESS告诉MQ消费成功,以MessageListener的consumeMessage为入口分析。 消费的时候,是以ConsumeReq
相关文章
相关标签/搜索