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

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