原文：rocketmq对 topic 、consumerGroup、tag（selectorExpress）组合配置
多个服务器的情况下： 相同topic consumerGroup tag 默认 均衡消费消息 相同topic consumerGroup 当存在不同Tag的时候，会导致消费混乱，比如TagA的消息被TagB的消费者消费了。 相同topic 不同consumerGroup 默认tag，每个服务器都会消费到所有消息 相同topic 不同consumerGroup 不同tag，只有存在和生产者相同的ta ...
2021-05-12 13:56 0 650 推荐指数：
相关推荐
转载 https://blog.csdn.net/a417930422/article/details/50663639 1 同一个订阅组内不同Consumer实例订阅不同topic消费混乱问题调查 图1： 背景说明 ...
本文主要介绍RocketMQ中Topic、Tag、GroupName的概念、设计初衷以及使用方法。 一.Topic 首先看看官方的定义： Topic是生产者在发送消息和消费者在拉取消息的类别。Topic与生产者和消费者之间的关系非常松散。 具体来说，一个Topic ...
最近做的项目的一个版本需求中，需要用到MQ,对数据记录进行异步落库，这样可以减轻数据库的压力,同时可以抗住大量的数据落库。这里需要说明一下本人用到的MQ是公司自己在阿里的RokectMQ的基础上进行封 ...
待续 ...
新增topic是需要客户端直接通知broker完成的： 通过createAndUpdateTopicConfig方法 发送给broker以后，在AdminBrokerProcessor里面负责处理这个类型消息： private synchronized ...
tag 的使用场景：不同的消费组，订阅同一 topic 不同的 tag，拉取不同的消息并消费。在 topic 内部对消息进行隔离。 producer 发送消息，指定 tag consumer 订阅 topic，指定 tag broker 存储 consumer ...