源码分析RocketMQ之消息消费重试机制

主要关注业务方在消息消费失败后,返回 ConsumeConcurrentlyStatus.RECONSUME_LATER ,专业术语:业务方每条消息消费后要告诉 MQ 消费者一个结果(ack,message back),触发 MQ 消息消费重试机制,然后 MQ 消费者需要反馈给 MQ(Broker)。 备注:主要针对的还是非顺序消息,顺序消息在后续专题详细分析。 1、消息消费处理 代码入口:Con
相关文章
相关标签/搜索