分布式消息服务-RocketMQ

创建订阅组

2024-07-02 02:24:04

场景描述

在RocketMQ中,创建订阅组的场景可以有以下几种情况:

l  消息负载均衡:当一个主题的消息量较大时,可以创建多个消费者,并将它们加入同一个订阅组。RocketMQ会根据消费者的负载均衡策略,将消息均匀地分发给订阅组中的消费者,从而实现消息的负载均衡。

l  高可用性:为了提高消费者的可用性和容错能力,可以创建多个消费者,并将它们加入同一个订阅组。当其中一个消费者发生故障或停止运行时,RocketMQ会将该消费者的消息重新分发给订阅组中的其他消费者,从而实现高可用性。

l  消费者水平扩展:当需要提高消费能力时,可以创建多个消费者,并将它们加入同一个订阅组。RocketMQ会根据消费者的数量和负载均衡策略,将消息均匀地分发给订阅组中的消费者,从而提高消费能力。

l  消费者组管理:通过创建订阅组,可以对一组具有相同消费逻辑的消费者进行管理。例如,可以对相同业务逻辑的消费者进行分组,并为每个订阅组设置不同的消费策略、消费进度等参数。

需要注意的是,创建订阅组时需要为其指定一个唯一的名称,以便在RocketMQ中进行标识和管理。同时,订阅组可以订阅一个或多个主题,以满足不同业务场景的需求。

总之,通过创建订阅组,可以实现消息的负载均衡、高可用性和消费者水平扩展,同时方便对消费者组进行管理和配置。

新增订阅组

     1、进入订阅管理菜单,点击【新建】按钮 

2、 在弹出的新建订阅组窗口填写相应字段。

1)默认展示当前集群名称,不可修改。

2)填写订阅组名称,名字限制2到64个字符,超过限制会导致创建订阅组失败,用户创建订阅组只能包含大小写字母数字以及_和-符号。

3)按照实际需求填写主题备注。

4)选择订阅组所在的Broker,按照实例创建时候选择的主备节点对数列出每个broker,可复选。

5)选择是否开启消费,默认开启消费。

3、 完成订阅组信息填写后,保存确认即可新增订阅组。

4、 若希望批量创建订阅组,可点击【批量创建】按钮

l  批量创建

注意:注意输入的订阅组名不要带空格等特殊字符

通过csv格式模板上传,批量创建订阅组。格式:点击【订阅组模板】按钮下载。

l  订阅组模板

指批量上传订阅组的模板,必须使用模板,才能够上传成功。


SLlfz2U550dp