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
Test
RAM authorization
|
Action |
Access level |
Resource type |
Condition key |
Dependent action |
|
rocketmq:ResetConsumeOffset |
update |
*ConsumerGroup
|
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:
|
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.