分布式消息服务ROCKETMQ版-通过Topic和Tag实现消息分类:不同消费者消费不同Tag

时间:2024-10-15 17:23:21

不同消费者消费不同Tag

在实际使用场景中,可能会遇到不同的消费者消费同一Topic的不同Tag消息。对于同一个Topic的不同Tag,如果RocketMQ消费者设置了相同的消费组,会导致消息消费混乱。

例如Topic A下有Tag A和Tag B,消费者A订阅了Tag A的消息,消费者B订阅了Tag B的消息。

如果消费者A和消费者B设置了相同的消费组,当生产者发送Tag A的消息时,Tag A的消息会均匀发送给消费者A和消费者B。由于消费者B没有订阅Tag A的消息,会把Tag A消息过滤掉,从而导致部分Tag A消息未被消费。

图1 错误的消费组设置

这种情况下,把消费者A和消费者B设置不同的消费组,即可解决消费混乱的问题。

图2 正确的消费者组设置
support.huaweicloud.com/bestpractice-hrm/hrm-bp-003.html