操作场景
Group 用于标识一类 Consumer,这类 Consumer 通常消费同一类消息,且消息订阅的逻辑一致。
该任务指导您使用消息队列 TDMQ RocketMQ 版时在控制台上创建,删除和查询 Group。
前提条件
需要提前创建好对应的命名空间。
根据 TDMQ 提供的 SDK 创建好消息的生产者和消费者并正常运行。
操作步骤
创建 Group
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 基本信息及客户端连接列表。
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 消费模式下的消费者组,否则会出现重置失败的情况。
编辑 Group
1. 在 Group 列表中,单击目标 Group 操作列的编辑。
?
?2. 在弹窗中,对 Group 信息进行编辑。
3. 单击提交,完成修改。
删除 Group
批量删除:在 Group 列表中,勾选所有需要删除的 Group,单击左上角的批量删除,在弹出的提示框中,单击删除,完成删除。
单个删除:在 Group 列表中,找到需要删除的 Group,单击操作列的删除,在弹出的提示框中,单击删除,完成删除。
?
?
?注意:
删除 Group 后,由该 Group 标识的消费者将立即停止接收消息,该 Group 下的所有配置将会被清空,且无法恢复,请您谨慎执行该操作。
元数据导入导出
元数据导出
您可以通过 Group 列表页右上角的
?
按钮直接导出元数据,元数据的导出格式为 .xlsx 格式的表格文件。元数据导入
如果您需要将一个集群的 Group 信息载入到另一个集群内,在导出元数据后,您可以点击 Group 列表页右上角的
?
按钮,将 Group 数据导入到指定的命名空间下。