場景描述
在RocketMQ中,消費組(Consumer Group)是一種邏輯上的概念,用于標識一組消費者(Consumer)的集合,這些消費者共同消費同一個主題(Topic)的消息。
消費組的概念允許多個消費者同時消費同一個主題的消息,從而實現消息的負載均衡和高可用性。當一個消息發送到RocketMQ中的某個主題時,RocketMQ會將該消息推送給訂閱了該Topic的所有消費組中的消費者。
每個消費組可以包含一個或多個消費者,這些消費者可以在同一個應用程序中或不同的應用程序中運行。消費者可以以集群模式(Cluster Mode)或廣播模式(Broadcast Mode)進行消費。
在集群模式下,消費組中的消費者以消費者組的形式協同工作,每個消息只會被消費組中的一個消費者消費。RocketMQ會根據消費者的負載均衡策略,將消息分發給不同的消費者,實現消息的負載均衡和高可用性。
在廣播模式下,消費組中的每個消費者都會獨立消費消息,每個消息會被消費組中的所有消費者都消費一次。廣播模式適用于需要所有消費者都處理同一份消息的場景。
消費組的概念使得RocketMQ能夠支持水平擴展和容錯能力。通過增加消費者數量或部署多個消費者實例,可以提高消費能力和可用性。
需要注意的是,每個消費組在RocketMQ中必須具有唯一的名稱,以便區分不同的消費組。同時,每個消費組可以訂閱一個或多個Topic,以滿足不同業務場景的需求。
消費組列表
1、 進入消費組管理菜單查看消費組列表,若列表為空則新建消費組,創建消費組詳情見具體操作步驟。
2、 支持按照集群、Broker和訂閱組名查詢,下拉選擇或者輸入查詢內容,點擊【查詢】按鈕即可展示需要的訂閱組數據。
3、 查看訂閱組基本信息,包括訂閱組名、BrokerName、BrokerID、起始消費位置、消費機制、是否開啟消費,可點擊【開啟消費】和【關閉消費】進行切換。
Topic列表
“Topic列表”:查看該消費組可消費的topic列表,及消費TPS限制情況。
1、 支持輸入關鍵字進行主題數據搜索。
2、 勾選需要消費的主題,保存確認。
3、 也可選擇全部訂購或者取消訂購。

下載
將勾選的訂閱組,導出其配置及路由情況,為excel文件,導出格式如下:

備注:
如果勾選了訂閱組,則導出勾選的訂閱組;如果沒有勾選,則導出該集群,選定broker下的所有訂閱組信息。