更新时间:2024-04-07 GMT+08:00

创建消费组

操作场景

消费组,即一组具有相同行为的消费者集合,用于管理和维护消息的消费状态。

前提条件

已创建RocketMQ实例。

操作步骤

  1. 登录管理控制台。
  2. 在管理控制台左上角单击,选择区域。

    请选择RocketMQ实例所在的区域。

  3. 在管理控制台左上角单击,选择“应用服务 > 分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ专享版页面。
  4. 单击RocketMQ实例的名称,进入实例详情页面。
  5. 在左侧导航栏,单击“消费组管理”,进入消费组列表页面。
  6. 单击“创建消费组”,弹出“创建消费组”页面。
  7. 参考表1,填写消费组名称和配置信息。

    表1 消费组参数说明

    参数

    说明

    消费组名称

    您可以自定义消费组名称,用于区别不同的消费行为。

    创建消费组后不能修改名称。

    关联代理

    选择在某个或者某几个代理上创建消费组。

    创建消费组后不能修改关联代理。

    最大重试次数

    设置普通消费的最大重试次数。

    如果是顺序消费,可通过消费者的setMaxReconsumeTimes函数配置。

    是否允许以广播模式消费

    是否设置为广播消费。

    若开启广播消费,每条消息都会被消费组内的所有消费者消费一次。否则,每条消息只会被消费组内的某一消费者消费。

  8. 配置完成后,单击“确定”,完成消费组的创建。