全部產品
Search
文件中心

ApsaraMQ for RocketMQ:ResetConsumeOffset - 重設消費位點

更新時間:Dec 21, 2025

重設指定消費者分組的消費位點。重設消費位點是指改變訂閱者當前的消費位置。當消費者出現故障或者消費錯誤資料時,您可通過重設消費位點將消費位置復原到之前的某個位點重新開始消費,您也可以將消費位置移動至最新位點,暫時不處理堆積的訊息。

調試

您可以在OpenAPI Explorer中直接運行該介面,免去您計算簽名的困擾。運行成功後,OpenAPI Explorer可以自動產生SDK程式碼範例。

調試

授權資訊

下表是API對應的授權資訊,可以在RAM權限原則語句的Action元素中使用,用來給RAM使用者或RAM角色授予調用此API的許可權。具體說明如下:

  • 操作:是指具體的許可權點。

  • 存取層級:是指每個操作的存取層級,取值為寫入(Write)、讀取(Read)或列出(List)。

  • 資源類型:是指操作中支援授權的資源類型。具體說明如下:

    • 對於必選的資源類型,用前面加 * 表示。

    • 對於不支援資源級授權的操作,用全部資源表示。

  • 條件關鍵字:是指雲產品自身定義的條件關鍵字。

  • 關聯操作:是指成功執行操作所需要的其他許可權。操作者必須同時具備關聯操作的許可權,操作才能成功。

操作

存取層級

資源類型

條件關鍵字

關聯操作

rocketmq:ResetConsumeOffset

update

*ConsumerGroup

acs:rocketmq:{#regionId}:{#accountId}:instance/{#InstanceId}/consumergroup/{#ConsumerGroupId}

請求文法

PATCH /instances/{instanceId}/consumerGroups/{consumerGroupId}/consumeOffsets/{topicName} HTTP/1.1

路徑參數

名稱

類型

必填

描述

樣本值

instanceId

string

雲訊息佇列 RocketMQ 版的執行個體 ID。

rmq-cn-tl32ue44x0g

consumerGroupId

string

消費者分組 ID。

dolphin_status

topicName

string

消費者分組訂閱的主題名稱。

AMZN_REPORT_TOPIC

請求參數

名稱

類型

必填

描述

樣本值

body

object

請求體對象。

resetType

string

重設方式。

  • LATEST_OFFSET:從最新位點開始消費。

    Group ID 消費指定 Topic 中的訊息時,會跳過當前堆積(未被消費)的所有訊息,從重設操作時間後發送的最新訊息開始消費。

  • SPECIFIED_TIME:從指定時間的位點開始消費。

    • 消費者將從重設時間對應的消費位點之後的訊息進行消費,不管這些訊息是否已被消費過。

    • 可選時間範圍中的起始和終止時間分別是該 Topic 中儲存的最早的和最晚的一條訊息的生產時間,不能選擇超過可選時間範圍的時間點。

    • 重設到某一時刻對應的消費位點,匹配位點時,服務端會根據自動匹配到該時刻最接近的消費位點。

枚舉值:

  • SPECIFIED_TIME :

    從指定時間的位點開始消費

  • LATEST_OFFSET :

    從最新位點開始消費

LATEST_OFFSET

resetTime

string

指定重設時間。表示消費者將從該時間點對應的消費位點重新開始消費訊息。

僅當 resetType(重設方式)選擇 SPECIFIED_TIME(指定時間)時需要填寫該參數。

格式為 YYYY-MM-DD HH:mm:ss,例如:2023-11-23 10:00:00。

2023-03-22 12:17:08

返回參數

名稱

類型

描述

樣本值

object

Result

requestId

string

請求 ID

F9A95891-EAD4-5A2B-8A30-676CD18921AF

success

boolean

是否成功

true

code

string

錯誤碼

MissingInstanceId

message

string

錯誤資訊

The instance cannot be found.

httpStatusCode

integer

HTTP 狀態代碼

200

dynamicCode

string

動態錯誤碼

InstanceId

dynamicMessage

string

動態錯誤資訊

instanceId

樣本

正常返回樣本

JSON格式

{
  "requestId": "F9A95891-EAD4-5A2B-8A30-676CD18921AF",
  "success": true,
  "code": "MissingInstanceId",
  "message": "The instance cannot be found.",
  "httpStatusCode": 200,
  "dynamicCode": "InstanceId",
  "dynamicMessage": "instanceId"
}

錯誤碼

訪問錯誤中心查看更多錯誤碼。

變更歷史

更多資訊,參考變更詳情