Membuat kelompok konsumen di ApsaraMQ for RocketMQ 5.0.
Sintaks
{
"Type": "ALIYUN::ROCKETMQ5::ConsumerGroup",
"Properties": {
"ConsumerGroupId": String,
"InstanceId": String,
"ConsumeRetryPolicy": Map,
"DeliveryOrderType": String,
"Remark": String
}
}
Properti
|
Property name |
Type |
Required |
Update allowed |
Description |
Constraints |
|
ConsumerGroupId |
String |
Yes |
No |
ID kelompok konsumen. |
ID harus unik secara global. Nilai harus memenuhi persyaratan berikut:
|
|
InstanceId |
String |
Yes |
No |
ID instans tempat kelompok konsumen tersebut berada. |
None |
|
ConsumeRetryPolicy |
Map |
Yes |
Yes |
Kebijakan pengulangan untuk kelompok konsumen. |
None |
|
DeliveryOrderType |
String |
Yes |
Yes |
Urutan pengiriman pesan dari kelompok konsumen. |
Nilai yang valid:
|
|
Remark |
String |
No |
Yes |
Keterangan kustom untuk kelompok konsumen. |
None |
Sintaks ConsumeRetryPolicy
"ConsumeRetryPolicy": {
"RetryPolicy": String,
"MaxRetryTimes": Integer,
"DeadLetterTargetTopic": String
}
Properti ConsumeRetryPolicy
|
Property name |
Type |
Required |
Update allowed |
Description |
Constraints |
|
RetryPolicy |
String |
Yes |
Yes |
Jenis kebijakan pengulangan. |
Nilai yang valid:
|
|
MaxRetryTimes |
Integer |
No |
Yes |
Jumlah maksimum upaya pengulangan. |
None |
|
DeadLetterTargetTopic |
String |
No |
Yes |
Topik dead-letter tempat pesan yang gagal dikonsumsi dialihkan. |
Jika konsumen gagal mengonsumsi pesan setelah mencapai jumlah maksimum upaya pengulangan, pesan tersebut akan dialihkan ke topik dead-letter untuk pemulihan bisnis atau troubleshooting. Untuk informasi selengkapnya, lihat Consumption retry. |
Nilai kembalian
Fn::GetAtt
-
ConsumerGroupId: ID kelompok konsumen.
-
InstanceId: ID instans tempat kelompok konsumen tersebut berada.
-
DeliveryOrderType: Urutan pengiriman pesan dari kelompok konsumen.
Contoh
ROSTemplateFormatVersion: '2015-09-01'
Parameters:
ConsumerGroupId:
Type: String
Description: |-
ID kelompok konsumen yang akan dibuat. ID ini harus unik secara global.
Nilainya dapat terdiri dari 1 hingga 60 karakter dan boleh mengandung huruf (a hingga z dan A hingga Z), angka (0 hingga 9), garis bawah (_), tanda hubung (-), dan tanda persen (%).
MinLength: 1
MaxLength: 60
InstanceId:
Type: String
Description: ID instans.
Resources:
ConsumerGroup:
Type: ALIYUN::ROCKETMQ5::ConsumerGroup
Properties:
ConsumerGroupId:
Ref: ConsumerGroupId
InstanceId:
Ref: InstanceId
ConsumeRetryPolicy:
RetryPolicy: DefaultRetryPolicy
MaxRetryTimes: 5
DeliveryOrderType: Concurrently
Outputs:
ConsumerGroupId:
Description: ID kelompok konsumen.
Value:
Fn::GetAtt:
- ConsumerGroup
- ConsumerGroupId
InstanceId:
Description: ID instans.
Value:
Fn::GetAtt:
- ConsumerGroup
- InstanceId
DeliveryOrderType:
Description: Urutan pengiriman kelompok konsumen.
Value:
Fn::GetAtt:
- ConsumerGroup
- DeliveryOrderType{
"ROSTemplateFormatVersion": "2015-09-01",
"Parameters": {
"ConsumerGroupId": {
"Type": "String",
"Description": "ID kelompok konsumen yang akan dibuat. ID ini harus unik secara global.\nNilainya dapat terdiri dari 1 hingga 60 karakter dan boleh mengandung huruf (a hingga z dan A hingga Z), angka (0 hingga 9), garis bawah (_), tanda hubung (-), dan tanda persen (%).",
"MinLength": 1,
"MaxLength": 60
},
"InstanceId": {
"Type": "String",
"Description": "ID instans."
}
},
"Resources": {
"ConsumerGroup": {
"Type": "ALIYUN::ROCKETMQ5::ConsumerGroup",
"Properties": {
"ConsumerGroupId": {
"Ref": "ConsumerGroupId"
},
"InstanceId": {
"Ref": "InstanceId"
},
"ConsumeRetryPolicy": {
"RetryPolicy": "DefaultRetryPolicy",
"MaxRetryTimes": 5
},
"DeliveryOrderType": "Concurrently"
}
}
},
"Outputs": {
"ConsumerGroupId": {
"Description": "ID kelompok konsumen.",
"Value": {
"Fn::GetAtt": [
"ConsumerGroup",
"ConsumerGroupId"
]
}
},
"InstanceId": {
"Description": "ID instans.",
"Value": {
"Fn::GetAtt": [
"ConsumerGroup",
"InstanceId"
]
}
},
"DeliveryOrderType": {
"Description": "Urutan pengiriman kelompok konsumen.",
"Value": {
"Fn::GetAtt": [
"ConsumerGroup",
"DeliveryOrderType"
]
}
}
}
}