场景描述
在RocketMQ中,创建消费组的场景可以有以下几种情况:
● 消息负载均衡:当一个Topic的消息量较大时,可以创建多个消费者,并将它们加入同一个消费组。RocketMQ会根据消费者的负载均衡策略,将消息均匀地分发给消费组中的消费者,从而实现消息的负载均衡。
● 高可用性:为了提高消费者的可用性和容错能力,可以创建多个消费者,并将它们加入同一个消费组。当其中一个消费者发生故障或停止运行时,RocketMQ会将该消费者的消息重新分发给消费组中的其他消费者,从而实现高可用性。
● 消费者水平扩展:当需要提高消费能力时,可以创建多个消费者,并将它们加入同一个消费组。RocketMQ会根据消费者的数量和负载均衡策略,将消息均匀地分发给消费组中的消费者,从而提高消费能力。
● 消费者组管理:通过创建消费组,可以对一组具有相同消费逻辑的消费者进行管理。例如,可以对相同业务逻辑的消费者进行分组,并为每个消费组设置不同的消费策略、消费进度等参数。
需要注意的是,创建消费组时需要为其指定一个唯一的名称,以便在RocketMQ中进行标识和管理。同时,消费组可以消费一个或多个Topic,以满足不同业务场景的需求。
总之,通过创建消费组,可以实现消息的负载均衡、高可用性和消费者水平扩展,同时方便对消费者组进行管理和配置。
新增消费组
1、进入消费组管理菜单,点击【创建消费组】按钮
2、 在弹出的新建消费组窗口填写相应字段。
1)默认展示当前集群名称,不可修改。
2)填写消费组名称,名字限制2到64个字符,超过限制会导致创建消费组失败,用户创建消费组只能包含大小写字母数字以及_和-符号。
3)按照实际需求填写消费组备注。
4)选择消费组所在的Broker,按照实例创建时候选择的主备节点对数列出每个broker,可复选。
5)选择是否开启消费,默认开启消费。
3、 完成消费组信息填写后,保存确认即可新增消费组。
4、 若希望批量创建消费组,可点击【导入消费组】按钮
- 批量创建
注意:注意输入的订阅组名不要带空格等特殊字符
通过csv格式模板上传,批量创建订阅组。格式:点击【订阅组模板】按钮下载。
- 消费组模板
指批量上传消费组的模板,必须使用模板,才能够上传成功,模板格式如下: