原文:rocketmq 動態設置topic和consumerGroup

...

2021-05-12 18:43 0 1137 推薦指數:

查看詳情

rocketmqtopicconsumerGroup、tag(selectorExpress)組合配置

多個服務器的情況下: 相同 topicconsumerGroup tag 默認 均衡消費消息 相同 topicconsumerGroup 當存在不同Tag的時候,會導致消費混亂,比如TagA的消息被TagB的消費者消費了。 相同topic 不同consumerGroup 默認 ...

Wed May 12 21:56:00 CST 2021 0 650
rocketmq如何新增topic

新增topic是需要客戶端直接通知broker完成的: 通過createAndUpdateTopicConfig方法 發送給broker以后,在AdminBrokerProcessor里面負責處理這個類型消息: private synchronized ...

Mon Dec 09 04:21:00 CST 2019 0 1461
RocketMQRocketMQ指定Topic對應的MessageQueue的數量

  項目中使用了RocketMQ,沒有顯式的創建和Topic和MessageQueue,在消息發送時,就創建了Topic和 4個 MessageQueue   此時想要修改MessageQueue的數量方式如下: 通過producer.createTopic方法創建; 通過控制台方式 ...

Tue Jul 06 09:02:00 CST 2021 0 960
rocketMQ No route info of this topic 錯誤

最近在使用rocketmq 發送消息,出現了No route info of this topic 異常,但奇怪的是我的其它的服務都可以成功發送,唯有crs服務不能成功發送,在網上搜索的解決方式基本上都是: ocketmq運行時提示 No route info of this topic 異常 ...

Mon Apr 29 22:53:00 CST 2019 0 7340
RocketMQTopic、Tag、GroupName的設計初衷

本文主要介紹RocketMQTopic、Tag、GroupName的概念、設計初衷以及使用方法。 一.Topic 首先看看官方的定義: Topic是生產者在發送消息和消費者在拉取消息的類別。Topic與生產者和消費者之間的關系非常松散。 具體來說,一個Topic ...

Tue Mar 31 16:50:00 CST 2020 0 3505
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM