版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/qq_27399407/article/details/85081203
近期做了一个开发,大致写了这么个东西:rocketMq 用同一个consumeID,起了两个listener,分别接收了同一个topic中的不同tag中的数据。
出现的问题:消费端有时候可以收到数据,有时间收不到数据。
经运维同事查了消费轨迹发现,问题出在订阅关系不一致。
rocketMq描述订阅关系不一致:在不同的 JVM 中启动了多个 Consumer,并且给相同的 Consumer ID 配置了不同的 Topic,或者是相同的 Topic 但 Tag 不同,最终导致订阅关系不一致,消息不符合预期。