租户端 互联网中间件 消息队列 RocektMQ 版 操作指南

Group 管理

最近更新时间: 2026-06-30 15:06:00

操作场景

Group 用于标识一类 Consumer，这类 Consumer 通常消费同一类消息，且消息订阅的逻辑一致。用户在启动消费者客户端时，需要先在控制台创建对应的 Group。

操作步骤

创建 Group

  1. 登录 RocketMQ 控制台，选择地域后，单击目标集群的“ID”进入集群基本信息页面。

  2. 单击顶部 Group 页签，选择命名空间后，单击新建进入创建 Group 页面。

  3. 填写 Group 相关信息。
    5.x 集群

    • Group 名称：填写 Group 名称（创建后不可修改），只能包含字母、数字、“%”、“-”及“_”，3-100个字符
    • Group 说明：填写 Group 说明，最长128字符
    • 最大重试次数：表示消息可以重新被投递的最大次数，超过最大重试次数还没被成功消费，消息将被投递至死信队列或丢弃。
      • 如果您使用的是 RocketMQ 4.x 客户端，消息的重试次数以您在客户端内设置消息重试次数为准。
      • 如果您使用的是 RocketMQ 5.x 客户端，则消息重试次数以您在当前页面设置的为准。
    • 投递顺序性：服务端将消息投递给消费者消费的顺序，支持顺序投递和并发投递，默认投递方式为并发投递。
      • 顺序投递：将逻辑上相关联的消息路由至同一队列并串行化处理，从而严格保证消息按其发送顺序被消费的机制。
      • 并发投递：指消息队列通过将消息分发至多个队列并由多个消费者线程并行处理，旨在最大化系统吞吐量与资源利用率，不保障消息间的处理顺序。
    • 开启消费：关闭后 Group 下的所有消费会暂停，重新开启可继续消费。可用于系统运维，对消费者组进行流控与故障隔离，以实现集群级别的保护与平滑操作。
      4.x 集群
    • Group 名称：填写 Group 名称（创建后不可修改），3-87个字符，只能包含字母、数字、“-”及“_”
    • 协议类型：当前仅支持 TCP 协议
    • Group 说明：填写 Group 说明
    • 开启消费：关闭后 Group 下的所有消费会暂停，重新开启可继续消费。可用于系统运维，对消费者组进行流控与故障隔离，以实现集群级别的保护与平滑操作。
    • 开启广播模式：关闭后 Group 下的所有声明为广播模式的消费者会暂停，重新开启可继续消费。
      • 集群消费：当使用集群消费模式时，任意一条消息只需要被集群内的任意一个消费者处理即可。
      • 广播消费：当使用广播消费模式时，每条消息会被推送给集群内所有注册过的消费者，保证消息至少被每个消费者消费一次。

  4. 单击提交，完成 Group 创建。

    说明：

    如果当前集群为单元化环境，Group 创建后会在其他单元创建相同的 Group 及配置。

查看消费者详情

  1. 在 Group 列表，单击 Group 的名称，可以查看 Group 详情。

    • 基本信息
      5.x 集群

      参数 说明
      Group 名称 Group 的名称。
      创建时间 Group 的创建时间。
      投递顺序性 服务端将消息投递给消费者消费的顺序，支持顺序投递和并发投递，默认投递方式为并发投递。
      - 顺序投递：将逻辑上相关联的消息路由至同一队列并串行化处理，从而严格保证消息按其发送顺序被消费的机制。
      - 并发投递：指消息队列通过将消息分发至多个队列并由多个消费者线程并行处理，旨在最大化系统吞吐量与资源利用率，不保障消息间的处理顺序。
      消费者类型 客户端获取消息的方式，支持 PUSH 或者 PULL。
      - PUSH 方式由客户端内部封装的长轮询机制来模拟服务端主动推送。
      - PULL 方式则由应用层主动调用客户端的拉取方法。
      总消息堆积 消息堆积的总数量。

      4.x 集群

      参数 说明
      Group 名称 Group 的名称。
      创建时间 Group 的创建时间。
      消费模式 集群模式或者广播模式。
      - 集群消费：当使用集群消费模式时，任意一条消息只需要被集群内的任意一个消费者处理即可。
      - 广播消费：当使用广播消费模式时，每条消息会被推送给集群内所有注册过的消费者，保证消息至少被每个消费者消费一次。
      客户端协议 仅支持 TCP 协议。
      总消息堆积 消息堆积的总数量。
      消费者类型 ACTIVELY（客户端主动拉消息，Pull 模式） 或 PASSIVELY（客户端等待服务端推消息，Push 模式）。

    • 客户端连接

      参数名 说明
      客户端地址 指客户端所在机器的 IP 地址和端口号。这个端口是客户端进程随机打开的本地端口，用于与 Broker 进行网络通信。
      主机名 客户端机器在操作系统层面配置的主机名称。
      客户端类型 仅5.x 集群展示。标识客户端的角色，主要是 Producer（生产者） 或 Consumer（消费者）。
      客户端语言 开发此客户端所使用的编程语言，如 JAVA、CPP、GO、DOTNET 等，RocketMQ 支持多语言客户端。
      客户端版本 客户端所使用的 RocketMQ 客户端库的版本，检查此字段有助于确认客户端版本是否与服务器兼容或是否存在已知 Bug。
      注意：
      请避免使用存在已知风险的客户端版本，详见各语言客户端风险说明。
      消息堆积 仅 4.x 集群展示。堆积的消息数量。
      操作 - 查看详情**：**可查看消费者详情。
      - 查看堆栈：可以查看该客户端的堆栈，也可以在堆栈上方搜索关键词，查看对应的堆栈信息。

    • 订阅关系

      参数名 含义说明
      Topic 该 Group 所订阅的 Topic 名称。
      类型 Topic 的类型，包括“普通消息、顺序消息、延时消息和事务消息”。
      消息堆积条数 当前 Group 的消息堆积中，各 Topic 下的消息条数
      队列数 该 Topic 下的队列总数，队列是 RocketMQ 进行负载均衡和并行消费的最小单元，一个消费者会分配到一个或多个队列进行消费。
      过滤模式 消费者订阅消息时的过滤方式。
      - TAG：标签过滤模式，通过设置消息的 Tag（标签）进行订阅，是最常用的方式。
      - SQL92：使用类 SQL 表达式对消息的 Property（用户属性）进行复杂过滤。
      订阅一致性 检查该消费者组下所有消费者实例的订阅关系是否一致。
      - 一致：所有消费者实例都订阅了完全相同的 Topic 和 Tag（或 SQL 表达式）。
      - 不一致：存在至少一个消费者实例的订阅关系与其他实例不同，这是导致消息丢失或混乱的常见原因，需修复。
      操作 如果当前 Group 没有在线客户端订阅某个 Topic，则可以在操作列单击取消订阅以清理历史订阅关系数据，避免历史脏数据的影响。

设置 offset

消费进度（offset）表示消费者消费消息的位置，在某些业务场景下，例如数据处理异常、业务逻辑变更或系统运维需求，可能会需要重置消费位点，以重新消费或跳过特定消息。

说明：

TDMQ-RocketMQ 支持给离线的 Group 重置 offset（消费位点），但目前仅支持 Push 消费模式下的消费者组，否则会出现重置失败的情况。

  1. 进入 Group 列表页面。

    • 5.x 集群：单击目标 Group 操作列的重置位点。
    • 4.x 集群：单击目标 Group 操作列的重置位点或者重置重试队列位点。
      关于重置重试队列位点的说明：
      特性 4.x 集群 5.x 集群
      重试队列粒度 以 Group 为单位
      一个 Group 只有一个重试队列，它订阅的所有 Topic 的失败消息都发到这里。      		 以 Group&Topic 为粒度
      一个 Group 针对它订阅的每个 Topic，都会有一个独立的专属重试队列。
      重置普通队列的影响 重置某个 Topic 的消费位点时，不会自动重置重试队列。 重置某个 Topic 的消费位点时，会自动重置与之对应的那个专属重试队列的位点。
      为何这样设计？ 为了避免“交叉影响”。
      如果一个 Group 订阅了 Topic A 和 Topic B，当重置 Topic A 的位点时，如果也重置了共用的重试队列，那么 Topic B 的失败消息也会被影响。      		 因为天然隔离。
      每个 Topic 都有自己独立的“重试队列”，重置 Topic A 时，只会动 Topic A 自己的重试队列，不会影响 Topic B 的重试队列，所以可以安全地自动完成。
      额外功能 提供了一个独立的 “重置重试队列位点” 功能。如果需要清除所有失败消息，可以单独执行这个操作。 无需额外功能，因为重置 Topic 时已自动处理。

  2. 在弹窗中，可以选择从最新位点开始或者从指定时间点开始设定 Topic 的消费位移 offset（即指定该订阅下的消费者从哪里开始消费消息）。
    如果选择重置位点“从最新位点开始”，则 Group 在指定 Topic 中的堆积消息将被全部清除，请谨慎操作。

  3. 单击提交，完成设置。

编辑 Group

  1. 在 Group 列表中，单击目标 Group 操作列的编辑。
  2. 在弹窗中，对 Group 信息进行编辑。
  3. 单击提交，完成修改。

删除 Group

  • 批量删除：在 Group 列表中，勾选所有需要删除的 Group，单击左上角的批量删除，在弹出的提示框中，单击提交，完成删除。
  • 单个删除：在 Group 列表中，找到需要删除的 Group，单击操作列的删除，在弹出的提示框中，单击提交，完成删除。

    注意：

    删除 Group 后，由该 Group 标识的消费者将立即停止接收消息，该 Group 下的所有配置将会被清空，且无法恢复，请您谨慎执行该操作。

导入和导出 Group 元数据

TDMQ RocketMQ 版支持在控制台上批量导入和导出 Group 元数据，以简化 Group 在多环境间的迁移、备份与批量配置。

  • **元数据导出：**通过 Group 列表页右上角的 按钮直接导出元数据，元数据的导出格式为 .xlsx 的表格文件。
  • **元数据导入：**如果您需要将一个集群的 Group 信息载入到另一个集群内，在导出元数据后，可以单击 Group 列表页右上角的 按钮，将 Group 数据导入到指定的集群内。