RocketMq相同topic不同tag踩坑

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

情景如下:

RocketMq相同topic不同tag踩坑

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

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

解决方法:

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

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

RocketMq相同topic不同tag踩坑

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

希望也能够解决大家的问题。