操作场景
消费组,即一组具有相同行为的消费者集合,用于管理和维护消息的消费状态。
前提条件
已购买RocketMQ实例。
操作步骤
-
登录分布式消息服务RocketMQ控制台。
-
单击RocketMQ实例的名称,进入实例详情页面。
-
在左侧导航栏,单击“消费组管理”,进入“消费组管理”页面。
-
单击“创建消费组”,弹出“创建消费组”页面。
图1 创建消费组
-
参考表1,填写消费组名称和配置信息。
表1 消费组参数说明
参数 | 说明 |
---|---|
消费组名称 | 您可以自定义消费组名称,用于区别不同的消费行为。 创建消费组后不能修改名称。 |
关联代理 | 选择在某个或者某几个代理上创建消费组。 创建消费组后不能修改关联代理。 |
最大重试次数 | 设置普通消费的最大重试次数。如果是顺序消费,可通过消费者的setMaxReconsumeTimes函数配置。 |
广播消费 | 是否设置为广播消费。 若开启广播消费,每条消息都会被消费组内的所有消费者消费一次。否则,每条消息只会被消费组内的某一消费者消费。 |
- 配置完成后,单击“确定”,完成消费组的创建。