更新时间:2025-07-11 GMT+08:00

创建RocketMQ消费组

消费组,即一组具有相同行为的消费者集合,用于管理和维护消息的消费状态。消费者可以将同一类的消费消息放在一个消费组里面,方便管理。

如果没有创建消费组,则RocketMQ会自动创建消费组。

约束与限制

消费组名称不能跨实例使用,例如实例A中创建的Group01不能在实例B中使用。

前提条件

已购买RocketMQ实例。

创建RocketMQ消费组

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

    不同区域的云服务产品之间内网互不相通。请就近选择靠近您业务的区域,可减少网络时延,提高访问速度。

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

    表1 消费组参数说明

    参数

    说明

    消费组名称

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

    消费组名称命名规则如下:
    • 长度为3~64个字符。
    • 只能由英文字母、数字、百分号、竖线、中划线、下划线组成。

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

    关联代理

    RocketMQ实例的版本为4.8.0时,需要设置此参数。

    选择需要创建消费组的代理,支持选择多个代理,可同步创建消费组,无需为每个代理单独创建。

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

    最大重试次数

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

    取值范围:1~16

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

    是否允许以广播模式消费

    是否设置为广播消费。

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

    是否顺序消费

    RocketMQ实例的版本为5.x时,需要设置此参数。

    开启顺序消费后,消费者将顺序消费消息。按顺序消费可以保证消息的消费顺序和发送的顺序一致,即先发送的先消费,后发送的后消费。

    描述

    消费组的描述信息。

    取值长度为0~200个字符。

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

    消费组创建完成后,消费组列表中会增加“消费组状态”和“消费模式”(仅4.8.0版本支持)。

    • “消费组状态”包含“在线”和“不在线”两种。
    • “消费模式”包含如下两种:
      • CLUSTERING:表示集群消费模式。当使用集群消费模式时,RocketMQ认为任意一条消息只需要被消费组内的任意一个消费者处理即可。
      • BROADCASTING:表示广播消费模式。当使用广播消费模式时,RocketMQ会将每条消息推送给消费组所有的消费者,保证消息至少被每个消费者消费一次。

      当消费组不在线时,“消费模式”取值显示为“--”。

相关文档