場景描述
在RocketMQ中,創建消費組的場景可以有以下幾種情況:
● 消息負載均衡:當一個Topic的消息量較大時,可以創建多個消費者,并將它們加入同一個消費組。RocketMQ會根據消費者的負載均衡策略,將消息均勻地分發給消費組中的消費者,從而實現消息的負載均衡。
● 高可用性:為了提高消費者的可用性和容錯能力,可以創建多個消費者,并將它們加入同一個消費組。當其中一個消費者發生故障或停止運行時,RocketMQ會將該消費者的消息重新分發給消費組中的其他消費者,從而實現高可用性。
● 消費者水平擴展:當需要提高消費能力時,可以創建多個消費者,并將它們加入同一個消費組。RocketMQ會根據消費者的數量和負載均衡策略,將消息均勻地分發給消費組中的消費者,從而提高消費能力。
● 消費者組管理:通過創建消費組,可以對一組具有相同消費邏輯的消費者進行管理。例如,可以對相同業務邏輯的消費者進行分組,并為每個消費組設置不同的消費策略、消費進度等參數。
需要注意的是,創建消費組時需要為其指定一個唯一的名稱,以便在RocketMQ中進行標識和管理。同時,消費組可以消費一個或多個Topic,以滿足不同業務場景的需求。
總之,通過創建消費組,可以實現消息的負載均衡、高可用性和消費者水平擴展,同時方便對消費者組進行管理和配置。
新增消費組
1、進入消費組管理菜單,點擊【創建消費組】按鈕
2、 在彈出的新建消費組窗口填寫相應字段。
1)默認展示當前集群名稱,不可修改。
2)填寫消費組名稱,名字限制2到64個字符,超過限制會導致創建消費組失敗,用戶創建消費組只能包含大小寫字母數字以及_和-符號。
3)按照實際需求填寫消費組備注。
4)選擇消費組所在的Broker,按照實例創建時候選擇的主備節點對數列出每個broker,可復選。
5)選擇是否開啟消費,默認開啟消費。
3、 完成消費組信息填寫后,保存確認即可新增消費組。
4、 若希望批量創建消費組,可點擊【導入消費組】按鈕
- 批量創建
注意:注意輸入的訂閱組名不要帶空格等特殊字符
通過csv格式模板上傳,批量創建訂閱組。格式:點擊【訂閱組模板】按鈕下載。
- 消費組模板
指批量上傳消費組的模板,必須使用模板,才能夠上傳成功,模板格式如下: