RocketMq相同topic不同tag踩坑
RocketMq在我们项目中一般用于系统间的解耦,有时候会使用不同的Consumer消费不同的tag,但是博主昨天踩了个坑。
情景如下:
两个consumer接收相同的topic,不同tag的消息,但是当处方系统发送tagA的消息的时候,consumer2消费了,本来consumer2应该是要丢弃掉的,但是却消费了,主要问题就是配置了相同的Group。
RocketMq消费者如果针对同一个topic不同的tag配置了相同的group,会导致消息消费混乱。
解决方法:
针对不同的tag配置不同的group即可。
解决效果可以从监控平台看到如下:
一个group过滤了消息,一个group消费了。
希望也能够解决大家的问题。