RocketMq在我们项目中一般用于系统间的解耦,有时候会使用不同的Consumer消费不同的tag,但是博主昨天踩了个坑。 情景如下: 两个consumer接收相同的topic,不同tag的消息,但是当处方系统发送tagA的消息的时候,consumer2消费了,本来consumer2应该是要丢弃掉的,但是却消费了,主要问题就是配置了相同的Group。 RocketMq消费者如果针对同一个topic不同的tag配置了相同的group,会导致消息消费混乱。 解决方法: 针对不同的tag配置不同的group即可。 解决效果可以从监控平台看到如下: 一个group过滤了消息,一个group消费了。 |
|手机版|小黑屋|梦想之都-俊月星空
( 粤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.