[GitHub] [rocketmq] leceshide edited a comment on issue #3171: How update queue offset when consumer occur Exception and return ConsumeConcurrentlyStatus.RECONSUME_LATER status

[GitBox <gi...@apache.org>]

leceshide edited a comment on issue #3171:
URL: https://github.com/apache/rocketmq/issues/3171#issuecomment-885761771


   > 1，是单个的消息
   > 2，无论消息消费成功还是失败 offset会一直往前走，ProcessQueue里的msgTreeMap是天然有序的（key是consumequeue的标号），这个方法是将queue里最老（最小）的msg给remove掉后，再将最老（最小）的msg的offset返回
   > 3，重试实际就是在消费一条新的消息，只是body和之前的消息是相同的
   > 4，在broker中配置messageDelayLevel可以自定义时间级别
   
   感谢 @zsmweiwei     @odbozhou  二位大神帮小弟指点迷津，现在明白了RocketMQ在这块的的设计原理，思路豁然开朗👍。
   
   我还想请教下，监控统计上的**消息积压**问题，我可以从哪些方面着手分析、验证并解决呢？
   
   再次感谢🙏


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org