Mereset offset konsumen dari sebuah grup konsumen. Jika Anda mereset offset konsumen, offset tempat konsumen mulai mengonsumsi pesan akan diubah. Jika terjadi kegagalan atau pesan yang salah dikonsumsi selama proses konsumsi pesan, Anda dapat mereset offset konsumen untuk mengembalikan konsumsi ke offset tertentu untuk konsumsi ulang. Anda juga dapat mereset offset konsumen ke offset terbaru dan untuk sementara membiarkan pesan yang menumpuk tidak ditangani.
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 grup konsumen. |
dolphin_status |
| topicName |
string |
Yes |
Nama topik. |
AMZN_REPORT_TOPIC |
Parameter permintaan
|
Parameter |
Type |
Required |
Description |
Example |
| body |
object |
No |
Isi permintaan. |
|
| resetType |
string |
No |
Metode yang digunakan untuk mereset offset konsumen. Nilai yang valid: LATEST_OFFSET dan SPECIFIED_TIME. Valid values:
|
LATEST_OFFSET |
| resetTime |
string |
No |
Waktu saat offset konsumen direset. |
2023-03-22 12:17:08 |
Elemen respons
|
Element |
Type |
Description |
Example |
|
object |
Hasil |
||
| 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.