上云无忧 > 文档中心 > 腾讯云消息队列 RocketMQ - Group 管理
消息队列 RocketMQ 版
腾讯云消息队列 RocketMQ - Group 管理

文档简介:
操作场景: Group 用于标识一类 Consumer,这类 Consumer 通常消费同一类消息,且消息订阅的逻辑一致。 该任务指导您使用消息队列 TDMQ RocketMQ 版时在控制台上创建,删除和查询 Group。
*此产品及展示信息均由腾讯云官方提供。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

操作场景

Group 用于标识一类 Consumer,这类 Consumer 通常消费同一类消息,且消息订阅的逻辑一致。
该任务指导您使用消息队列 TDMQ RocketMQ 版时在控制台上创建,删除和查询 Group。

前提条件

需要提前创建好对应的命名空间。
根据 TDMQ 提供的 SDK 创建好消息的生产者和消费者并正常运行。

操作步骤

创建 Group

5.x 集群
4.x 集群
1. 登录 RocketMQ 控制台
2. 在左侧导航栏中选择 Group 管理,选择地域和目标集群。

3. 单击新建进入创建 Group 页面。
4. 填写 Group 相关信息。
Group 名称:填写 Group 名称(创建后不可修改),3-64个字符,只能包含字母、数字、“-”及“_”。
Group 说明:填写 Group 说明。
最大重试次数:表示消息可以重新被投递的最大次数,超过最大重试次数还没被成功消费,消息将被投递至死信队列或丢弃。如果您使用的是 RocketMQ 4.x 客户端,消息的重试次数以您在客户端内设置消息重试次数为准。如果您使用的是 RocketMQ 5.x 客户端,则消息重试次数以您在当前页面设置的为准。
投递顺序性:服务端将消息投递给消费者消费的顺序,支持顺序投递和并发投递,默认投递方式为并发投递。
开启消费:关闭后 Group 下的所有消费会暂停,重新开启可继续消费。
5. 单击提交,完成 Group 创建。

1. 登录 TDMQ RocketMQ 版控制台,选择地域后,单击目标集群的“ID”进入集群基本信息页面。
2. 单击顶部 Group 页签,选择命名空间后,单击新建进入创建 Group 页面。
3. 填写 Group 相关信息。

Group 名称:填写 Group 名称(创建后不可修改),3-64个字符,只能包含字母、数字、“-”及“_”。
协议类型:支持 HTTP 和 TCP 协议。
Group 说明:填写 Group 说明。
开启消费:关闭后 Group 下的所有消费会暂停,重新开启可继续消费。
开启广播模式:关闭后 Group 下的所有声明为广播模式的消费者会暂停,重新开启可继续消费。
4. 单击提交,完成 Group 创建。
注意:
为了保障线上集群的稳定性,避免控制台的元数据冗余,腾讯云TDMQ-RocketMQ 于2023年2月底关闭了 group 自动创建的配置。用户在启动消费者客户端时,需要先在控制台创建对应的 Group。

查看消费者详情

1. Group 列表,点击 Group 名称,进入客户端连接列表,可以查看 Group 基本信息及客户端连接列表。
5.x 集群
4.x 集群
Group 名称
创建时间
投递顺序性:顺序投递或者并发投递
消费者类型:PUSH 或者 PULL
总消息堆积:消息堆积的总数量
消费模式:集群模式或者广播模式
集群消费:当使用集群消费模式时,任意一条消息只需要被集群内的任意一个消费者处理即可。
广播消费:当使用广播消费模式时,每条消息会被推送给集群内所有注册过的消费者,保证消息至少被每个消费者消费一次。
客户端协议:支持 TCP 和 HTTP 协议
总消息堆积:消息堆积的总数量
消费者类型:ACTIVELY(主动拉消息,Pull 模式) 或 PASSIVELY(客户端等待服务端推消息,Push 模式)
2. 单击客户端操作栏的查看详情可查看消费者详情。

3. 切换到订阅关系页签,可以查看该 Group 订阅的 Topic 列表与订阅属性。

设置 offset

1. 在 Group 列表中,单击目标 Group 操作列的重置位点

2. 在弹窗中,可以选择从最新位点开始或者按从指定时间点开始设定 Topic 的消费位移 offset(即指定该订阅下的消费者从哪里开始消费消息)。
3. 单击提交,完成设置。


说明:

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

4.x 集群
消费模式:集群模式或者广播模式
集群消费:当使用集群消费模式时,任意一条消息只需要被集群内的任意一个消费者处理即可。
广播消费:当使用广播消费模式时,每条消息会被推送给集群内所有注册过的消费者,保证消息至少被每个消费者消费一次。
客户端协议:支持 TCP 和 HTTP 协议
总消息堆积:消息堆积的总数量
消费者类型:ACTIVELY(主动拉消息,Pull 模式) 或 PASSIVELY(客户端等待服务端推消息,Push 模式)
单击客户端操作栏的查看详情可查看消费者详情。


切换到订阅关系页签,可以查看该 Group 订阅的 Topic 列表与订阅属性。

设置 offset
在 Group 列表中,单击目标 Group 操作列的重置位点。

在弹窗中,可以选择从最新位点开始或者按从指定时间点开始设定 Topic 的消费位移 offset(即指定该订阅下的消费者从哪里开始消费消息)。
单击提交,完成设置。


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


编辑 Group

1. 在 Group 列表中,单击目标 Group 操作列的编辑

2. 在弹窗中,对 Group 信息进行编辑。
3. 单击提交,完成修改。

删除 Group

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


注意:

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

元数据导入导出

元数据导出

您可以通过 Group 列表页右上角的

按钮直接导出元数据,元数据的导出格式为 .xlsx 格式的表格文件。

元数据导入

如果您需要将一个集群的 Group 信息载入到另一个集群内,在导出元数据后,您可以点击 Group 列表页右上角的

按钮,将 Group 数据导入到指定的命名空间下。



相似文档
  • 操作场景: TDMQ RocketMQ 支持监控您账户下创建的资源,包括集群、Topic、Group 等,您可以根据这些监控数据,分析集群的使用情况,针对可能存在的风险及时处理。同时您也可以对监控项设置报警规则,以便数据异常时收到报警消息,及时处理风险,保障系统的稳定运行。
  • 当一条消息从生产者发送到 TDMQ RocketMQ 版服务端,再由消费者进行消费,TDMQ RocketMQ 版会完整记录这条消息中间的流转过程,并以消息轨迹的形式呈现在控制台。 消息轨迹记录了消息从生产端到 TDMQ RocketMQ 版服务端,最后到消费端的整个过程,包括各阶段的时间(精确到微秒)、执行结果、生产者 IP、消费者 IP 等。
  • 为了给业务处理业务失败,给消息消费失败的情况兜底,保证消息生命周期的完整,RocketMQ 实现了消费失败后重试的策略。 如果您使用的是 RocketMQ 4.x 客户端,消息的重试次数以您在客户端内设置消息重试次数为准。
  • 操作场景: 死信队列是一种特殊的消息队列,用于集中处理无法被正常消费的消息的队列。当消息在达到一定重试次数后仍未能被正常消费,TDMQ RocketMQ 版会判定这条消息在当前情况下无法被消费,将其投递至死信队列。
  • 消息轨迹记录了消息从生产端到 TDMQ RocketMQ 版服务端,最后到消费端的整个过程,包括各阶段的时间(精确到微秒)、执行结果、生产者 IP、消费者 IP 等。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部