BlessingCR’s Blog
BlessingCR’s Blog

rocketmq 消费者收到了不应该收到的数据

问题/现象:

线上消费订阅为Topic-A 下有两个 consumer group A,B; 分别订阅 tag-A 与 tag-B

但是tag-B并未在使用(此前使用,后续暂时移除,计划过几个迭代后添加)

consumer group A订阅一切正常,但是 consumer group B开始收到A下消息

如下图某消息同时发到A和B

https://blessingcr.com/wp-content/uploads/2024/05/img_v3_02bd_5900b654-5eb0-4eb2-a65a-5adf7f40b91g.jpg

处理:

此时造成消息在consumer B下不断堆积,后续重新启动consumer B

https://blessingcr.com/wp-content/uploads/2024/05/img_v3_02bd_e2ddfbc5-1d70-4825-acf7-f4eeeba454eg.jpg

B下消息堆积立刻清空(不是被消费的,日志并未打印任何消息)

此时,原本的错误信息变为

https://blessingcr.com/wp-content/uploads/2024/05/EWng5H0WPT.jpg

查证:

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

没有标签
首页      rocketmq      rocketmq 消费者收到了不应该收到的数据

发表回复

textsms
account_circle
email

BlessingCR’s Blog

rocketmq 消费者收到了不应该收到的数据
问题/现象: 线上消费订阅为Topic-A 下有两个 consumer group A,B; 分别订阅 tag-A 与 tag-B 但是tag-B并未在使用(此前使用,后续暂时移除,计划过几个迭代后添加) consumer group A…
扫描二维码继续阅读
2024-05-31