分布式消息服务ROCKETMQ版-通过Topic和Tag实现消息分类:不同消费者消费不同Tag
不同消费者消费不同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消息未被消费。
这种情况下,把消费者A和消费者B设置不同的消费组,即可解决消费混乱的问题。
- RocketMQ主要应用场景有哪些_分布式消息中间件_分布式消息RocketMQ-华为云
- RocketMQ的架构_RocketMQ的消息模式_分布式消息RocketMQ-华为云
- RocketMQ是什么_RocketMQ介绍_分布式消息服务RocketMQ版
- 分布式消息中间件实战_分布式消息实战_分布式消息-华为云
- 分布式消息服务Kafka版与分布式消息服务RocketMQ版的区别_Kafka与RocketMQ对比_Kafka与RocketMQ差异
- kafka是什么_kafka介绍_分布式消息服务Kafka版
- Kafka与其他消息队列的对比_什么是Kafka_分布式消息系统-华为云
- 分布式消息服务有哪些_分布式消息服务哪个好_分布式消息-华为云
- 分布式消息中间件的作用_分布式消息中间件_分布式消息-华为云
- 分布式消息队列是什么_分布式消息队列好处_消息队列-华为云