问题/现象:
线上消费订阅为Topic-A 下有两个 consumer group A,B; 分别订阅 tag-A 与 tag-B
但是tag-B并未在使用(此前使用,后续暂时移除,计划过几个迭代后添加)
consumer group A订阅一切正常,但是 consumer group B开始收到A下消息
如下图某消息同时发到A和B

处理:
此时造成消息在consumer B下不断堆积,后续重新启动consumer B
此时,原本的错误信息变为

查证:
后查证: rocketmq 是 消费组订阅了topic后,topic所有消息都会发到所有消费组,然后消费组没有维护订阅关系,是消费者注册上了以后才有的,也就是消费组不知道他要消费什么tag,所以消费组下面没有消费者,造成了他不知道所有消息该不该过滤,于是造成消费堆积。
发表回复