jjzjj

ClientId

全部标签

关于 RocketMQ ClientID 相同引发的消息堆积的问题

首先,造成这个问题的BUGRocketMQ官方已经在3月16号的这个提交中修复了,这里只是探讨一下在修复之前造成问题的具体细节,更多的上下文可以参考我之前写的《RocketMQConsumer启动时都干了些啥?》,这篇文章讲解了RocketMQ的Consumer启动之后都做了哪些操作,对理解本次要讲解的BUG有一定的帮助。其中讲到了:重复消费自不必说,你ClientID都相同了。本篇着重聊聊为什么会消息堆积。文章中讲到,初始化Consumer时,会初始化Rebalance的策略。你可以大致将Rebalance策略理解为如何将一个Topic下的m个MessageQueue分配给一个Consume