RocketMq-RocketMQMessageListener
全部标签首先,造成这个问题的BUGRocketMQ官方已经在3月16号的这个提交中修复了,这里只是探讨一下在修复之前造成问题的具体细节,更多的上下文可以参考我之前写的《RocketMQConsumer启动时都干了些啥?》,这篇文章讲解了RocketMQ的Consumer启动之后都做了哪些操作,对理解本次要讲解的BUG有一定的帮助。其中讲到了:重复消费自不必说,你ClientID都相同了。本篇着重聊聊为什么会消息堆积。文章中讲到,初始化Consumer时,会初始化Rebalance的策略。你可以大致将Rebalance策略理解为如何将一个Topic下的m个MessageQueue分配给一个Consume
首先,造成这个问题的BUGRocketMQ官方已经在3月16号的这个提交中修复了,这里只是探讨一下在修复之前造成问题的具体细节,更多的上下文可以参考我之前写的《RocketMQConsumer启动时都干了些啥?》,这篇文章讲解了RocketMQ的Consumer启动之后都做了哪些操作,对理解本次要讲解的BUG有一定的帮助。其中讲到了:重复消费自不必说,你ClientID都相同了。本篇着重聊聊为什么会消息堆积。文章中讲到,初始化Consumer时,会初始化Rebalance的策略。你可以大致将Rebalance策略理解为如何将一个Topic下的m个MessageQueue分配给一个Consume
一次RocketMQ顺序消费延迟的问题定位问题背景与现象昨晚收到了应用报警,发现线上某个业务消费消息延迟了54s多(从消息发送到MQ到被消费的间隔):2021-06-30T23:12:46.756messageprocessingisincrediblydelayed!(Currentdelaytime:54725,incredibledelaycountin10seconds:5677)查看RocketMQ的监控,发现确实发生了比较多的消息积压:从RocketMQ-Console上面查看Topic的消费者:这个Topic,业务要求是需要有序的。所以在发送的时候,指定了业务Key,并且消费的时
一次RocketMQ顺序消费延迟的问题定位问题背景与现象昨晚收到了应用报警,发现线上某个业务消费消息延迟了54s多(从消息发送到MQ到被消费的间隔):2021-06-30T23:12:46.756messageprocessingisincrediblydelayed!(Currentdelaytime:54725,incredibledelaycountin10seconds:5677)查看RocketMQ的监控,发现确实发生了比较多的消息积压:从RocketMQ-Console上面查看Topic的消费者:这个Topic,业务要求是需要有序的。所以在发送的时候,指定了业务Key,并且消费的时