重置消费进度

最近更新时间:2025-11-14 11:05:51

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

约束与限制

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

操作步骤

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. 单击提交,完成设置。