消息队列 RocketMQ 版 重置消费进度

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

相关产品
消息队列 RocketMQ 版 产品页,含版本规格、价格与购买入口。

一、约束与限制

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

二、操作步骤

1. 登录 TDMQ RocketMQ 版控制台。

2. 在左侧导航栏选择资源管理 > 集群管理,选择好地域后,单击目标集群的“ID”,进入集群基本信息页面。

3. 在集群基本信息页面,选择 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 时已自动处理。

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

如果选择重置位点“从最新位点开始”,则 Group 在指定 Topic 中的堆积消息将被全部清除,请谨慎操作。

5. 单击提交,完成设置。

赞 (0)
上一篇 4天前
下一篇 4天前