原文：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 ...