All Products
Search
Document Center

ApsaraMQ for RocketMQ:ResetConsumeOffset

Last Updated:Dec 21, 2025

Mereset offset konsumen dari sebuah consumer group. Setelah offset konsumen direset, posisi awal konsumen dalam mengonsumsi pesan akan berubah. Jika terjadi kesalahan atau pesan dikonsumsi secara tidak benar selama proses konsumsi, Anda dapat mereset offset konsumen ke offset tertentu untuk melakukan reconsumption. Anda juga dapat mereset offset konsumen ke offset terbaru guna sementara waktu melewati pesan-pesan yang tertumpuk.

Coba sekarang

Coba API ini di OpenAPI Explorer tanpa perlu penandatanganan manual. Panggilan yang berhasil akan secara otomatis menghasilkan contoh kode SDK sesuai dengan parameter Anda. Unduh kode tersebut dengan kredensial bawaan yang aman untuk penggunaan lokal.

Test

RAM authorization

Tabel berikut menjelaskan otorisasi yang diperlukan untuk memanggil API ini. Anda dapat menentukannya dalam kebijakan Resource Access Management (RAM). Kolom pada tabel dijelaskan sebagai berikut:

  • Action: Aksi yang dapat digunakan dalam elemen Action pada pernyataan kebijakan izin RAM untuk memberikan izin guna melakukan operasi tersebut.

  • API: API yang dapat Anda panggil untuk melakukan aksi tersebut.

  • Access level: Tingkat akses yang telah ditentukan untuk setiap API. Nilai yang valid: create, list, get, update, dan delete.

  • Resource type: Jenis resource yang mendukung otorisasi untuk melakukan aksi tersebut. Ini menunjukkan apakah aksi tersebut mendukung izin tingkat resource. Resource yang ditentukan harus kompatibel dengan aksi tersebut. Jika tidak, kebijakan tersebut tidak akan berlaku.

    • Untuk API dengan izin tingkat resource, jenis resource yang diperlukan ditandai dengan tanda bintang (*). Tentukan Nama Sumber Daya Alibaba Cloud (ARN) yang sesuai dalam elemen Resource pada kebijakan.

    • Untuk API tanpa izin tingkat resource, ditampilkan sebagai All Resources. Gunakan tanda bintang (*) dalam elemen Resource pada kebijakan.

  • Condition key: Kunci kondisi yang didefinisikan oleh layanan. Kunci ini memungkinkan kontrol granular, berlaku baik hanya untuk aksi maupun untuk aksi yang terkait dengan resource tertentu. Selain kunci kondisi spesifik layanan, Alibaba Cloud menyediakan serangkaian common condition keys yang berlaku di semua layanan yang didukung RAM.

  • Dependent action: Aksi dependen yang diperlukan untuk menjalankan aksi tersebut. Untuk menyelesaikan aksi tersebut, pengguna RAM atau role RAM harus memiliki izin untuk melakukan semua aksi dependen.

Action

Access level

Resource type

Condition key

Dependent action

rocketmq:ResetConsumeOffset

update

*ConsumerGroup

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

None None

Sintaks permintaan

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

Path Parameters

Parameter

Type

Required

Description

Example

instanceId

string

Yes

ID instans.

rmq-cn-tl32ue44x0g

consumerGroupId

string

Yes

ID consumer group.

dolphin_status

topicName

string

Yes

Nama topik.

AMZN_REPORT_TOPIC

Parameter permintaan

Parameter

Type

Required

Description

Example

body

object

No

Badan permintaan.

resetType

string

No

Metode yang digunakan untuk mereset consumer offset. Nilai yang valid: LATEST_OFFSET dan SPECIFIED_TIME.

Valid values:

  • SPECIFIED_TIME :

    Mulai mengonsumsi dari offset pada waktu yang ditentukan.

  • LATEST_OFFSET :

    Mulai mengonsumsi dari offset terbaru.

LATEST_OFFSET

resetTime

string

No

Waktu saat consumer offset direset.

2023-03-22 12:17:08

Elemen respons

Element

Type

Description

Example

object

Result

requestId

string

ID permintaan.

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

success

boolean

Menunjukkan apakah permintaan berhasil.

true

code

string

Kode kesalahan yang dikembalikan.

MissingInstanceId

message

string

Pesan kesalahan yang dikembalikan.

The instance cannot be found.

httpStatusCode

integer

Kode status HTTP yang dikembalikan.

200

dynamicCode

string

Kode kesalahan dinamis yang dikembalikan.

InstanceId

dynamicMessage

string

Pesan kesalahan dinamis yang dikembalikan.

instanceId

Contoh

Respons sukses

JSONformat

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

Kode kesalahan

Lihat Error Codes untuk daftar lengkap.

Catatan rilis

Lihat Release Notes untuk daftar lengkap.