多个服务器的情况下： 相同 topic 、consumerGroup tag 默认 均衡消费消息 相同 topic 、consumerGroup 当存在不同Tag的时候，会导致消费混乱，比如TagA的消息被TagB的消费者消费了。 相同topic 不同consumerGroup 默认 ...

转载 https://blog.csdn.net/a417930422/article/details/50663639 1 同一个订阅组内不同Consumer实例订阅不同topic消费混乱问题调查 图1： 背景说明 ...

待续 ...

...

新增topic是需要客户端直接通知broker完成的： 通过createAndUpdateTopicConfig方法 发送给broker以后，在AdminBrokerProcessor里面负责处理这个类型消息： private synchronized ...

　　项目中使用了RocketMQ，没有显式的创建和Topic和MessageQueue，在消息发送时，就创建了Topic和 4个 MessageQueue 　　此时想要修改MessageQueue的数量方式如下： 通过producer.createTopic方法创建； 通过控制台方式 ...

最近在使用rocketmq 发送消息，出现了No route info of this topic 异常，但奇怪的是我的其它的服务都可以成功发送，唯有crs服务不能成功发送，在网上搜索的解决方式基本上都是： ocketmq运行时提示 No route info of this topic 异常 ...

本文主要介绍RocketMQ中Topic、Tag、GroupName的概念、设计初衷以及使用方法。 一.Topic 首先看看官方的定义： Topic是生产者在发送消息和消费者在拉取消息的类别。Topic与生产者和消费者之间的关系非常松散。 具体来说，一个Topic ...