京东6.18大促主会场领京享红包更优惠

 找回密码
 立即注册

QQ登录

只需一步,快速开始

RocketMq相同topic不同tag踩坑

2020-8-26 17:04| 发布者: zhaojun917| 查看: 4724| 评论: 0

摘要: RocketMq在我们项目中一般用于系统间的解耦,有时候会使用不同的Consumer消费不同的tag,但是博主昨天踩了个坑。情景如下:两个consumer接收相同的topic,不同tag的消息,但是当处方系统发送tagA的消息的时候,consu ...

RocketMq在我们项目中一般用于系统间的解耦,有时候会使用不同的Consumer消费不同的tag,但是博主昨天踩了个坑。

情景如下:

两个consumer接收相同的topic,不同tag的消息,但是当处方系统发送tagA的消息的时候,consumer2消费了,本来consumer2应该是要丢弃掉的,但是却消费了,主要问题就是配置了相同的Group。

RocketMq消费者如果针对同一个topic不同的tag配置了相同的group,会导致消息消费混乱。

解决方法:

针对不同的tag配置不同的group即可。

解决效果可以从监控平台看到如下:

一个group过滤了消息,一个group消费了。

关闭

站长推荐上一条 /6 下一条

QQ|手机版|小黑屋|梦想之都-俊月星空 ( 粤ICP备18056059号 )|网站地图

GMT+8, 2025-7-1 19:32 , Processed in 0.038073 second(s), 18 queries .

Powered by Mxzdjyxk! X3.5

© 2001-2025 Discuz! Team.

返回顶部