文档首页> 分布式消息服务RocketMQ版> API参考（吉隆坡区域）> API V2（推荐）> 消费组管理> 重置消费进度
更新时间：2024-04-08 GMT+08:00
在线调试
CLI示例
查看PDF

重置消费进度

功能介绍

重置消费进度。

URI

POST /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group_id}/reset-message-offset

表1 路径参数

参数

是否必选

参数类型

描述

engine

是

String

引擎类型：reliability。

缺省值：reliability

project_id

是

String

项目ID，获取方式请参见获取项目ID。

instance_id

是

String

实例ID。

group_id

是

String

消费组名称。

请求参数

表2 请求Body参数

参数

是否必选

参数类型

描述

topic

是

String

重置的主题。

timestamp

是

String

重置的时间。

响应参数

状态码： 200

表3 响应Body参数

参数

参数类型

描述

queues

Array of queues objects

重置的队列。
表4 queues

参数

参数类型

描述

broker_name

String

队列所在的broker。

queue_id

Integer

队列ID。

timestamp_offset

Long

重置消费进度。

请求示例

重置topic_01主题的消费进度到指定时间点。

POST https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group_id}/reset-message-offset

{
  "topic" : "topic_01",
  "timestamp" : 1662652800000
}

响应示例

状态码： 200

重置消费进度成功。

{
  "queues" : [ {
    "broker_name" : "broker-1",
    "queue_id" : 0,
    "timestamp_offset" : 0
  } ]
}

状态码

状态码

描述

200

重置消费进度成功。

错误码

请参见错误码。

父主题： 消费组管理