Membuat kelompok konsumen untuk ApsaraMQ for RocketMQ. Kelompok konsumen adalah grup load balancing yang terdiri atas beberapa konsumen dengan perilaku konsumsi yang sama. Konsumen harus menentukan kelompok konsumen dan topik terkait untuk berlangganan pesan.
Deskripsi operasi
Coba sekarang
Test
RAM authorization
|
Action |
Access level |
Resource type |
Condition key |
Dependent action |
|
rocketmq:CreateConsumerGroup |
create |
*ConsumerGroup
|
None | None |
Sintaks permintaan
POST /instances/{instanceId}/consumerGroups/{consumerGroupId} HTTP/1.1
Path Parameters
|
Parameter |
Type |
Required |
Description |
Example |
| instanceId |
string |
Yes |
ID instans tempat kelompok konsumen tersebut berada. |
rmq-cn-7e22ody**** |
| consumerGroupId |
string |
Yes |
ID kelompok konsumen yang ingin Anda buat. ID ini digunakan untuk mengidentifikasi kelompok konsumen dan harus unik secara global. Nilai harus memenuhi persyaratan berikut:
Untuk informasi lebih lanjut tentang karakter terlarang, lihat Batasan parameter. |
GID_test_groupId |
Parameter permintaan
|
Parameter |
Type |
Required |
Description |
Example |
| body |
object |
No |
Badan permintaan. |
|
| remark |
string |
No |
Keterangan untuk kelompok konsumen. |
This is the remark for test. |
| deliveryOrderType |
string |
Yes |
Urutan pengiriman untuk kelompok konsumen. Nilai yang valid:
Valid values:
|
Concurrently |
| consumeRetryPolicy |
object |
Yes |
Kebijakan retry untuk kelompok konsumen. Untuk informasi selengkapnya, lihat Message retry. |
|
| maxRetryTimes |
integer |
No |
Jumlah maksimum retry. |
16 |
| retryPolicy |
string |
Yes |
Jenis kebijakan retry. Untuk informasi selengkapnya, lihat Message retry. Nilai yang valid:
Valid values:
|
DefaultRetryPolicy |
| deadLetterTargetTopic |
string |
No |
Topik dead-letter. Jika konsumen gagal mengonsumsi pesan setelah mencapai jumlah maksimum retry, pesan tersebut akan dikirim ke topik dead-letter. Anda kemudian dapat melakukan pemulihan bisnis atau melacak kembali pesan tersebut. Untuk informasi selengkapnya, lihat Message retry and dead-letter messages. |
DLQ_mqtest |
| fixedIntervalRetryTime |
integer |
No |
Interval retry tetap. Satuan: detik. Parameter ini hanya berlaku jika Anda mengatur kebijakan retry ke FixedRetryPolicy. Nilai yang valid:
|
10 |
| maxReceiveTps |
integer |
No |
TPS maksimum untuk konsumsi pesan. |
1000 |
| messageModel |
string |
No |
Mode konsumsi. Nilai yang valid:
|
LITE_SELECTIVE |
| topicName |
string |
No |
Nama topik lite yang dilanggani oleh kelompok konsumen. Parameter ini wajib diisi jika Anda mengatur messageModel ke LITE_SELECTIVE. |
liteTopicTest |
Elemen respons
|
Element |
Type |
Description |
Example |
|
object |
Result<boolean> |
||
| requestId |
string |
ID permintaan. Setiap permintaan memiliki ID unik. Anda dapat menggunakan ID ini untuk pemecahan masalah dan pelacakan isu. |
AF9A8B10-C426-530F-A0DD-96320B39**** |
| success |
boolean |
Menunjukkan apakah panggilan berhasil. |
true |
| data |
boolean |
Data yang dikembalikan. |
true |
| code |
string |
Kode kesalahan. |
InvalidConsumerGroupId |
| message |
string |
Pesan kesalahan. |
Parameter consumerGroupId is invalid. |
| httpStatusCode |
integer |
Kode status HTTP. |
400 |
| dynamicCode |
string |
Kode kesalahan dinamis. |
ConsumerGroupId |
| dynamicMessage |
string |
Pesan kesalahan dinamis. |
consumerGroupId |
Contoh
Respons sukses
JSONformat
{
"requestId": "AF9A8B10-C426-530F-A0DD-96320B39****",
"success": true,
"data": true,
"code": "InvalidConsumerGroupId",
"message": "Parameter consumerGroupId is invalid.",
"httpStatusCode": 400,
"dynamicCode": "ConsumerGroupId",
"dynamicMessage": "consumerGroupId"
}
Kode kesalahan
Lihat Error Codes untuk daftar lengkap.
Catatan rilis
Lihat Release Notes untuk daftar lengkap.