Crie um grupo de consumidores no ApsaraMQ for RocketMQ 5.0.
Sintaxe
{
"Type": "ALIYUN::ROCKETMQ5::ConsumerGroup",
"Properties": {
"ConsumerGroupId": String,
"InstanceId": String,
"ConsumeRetryPolicy": Map,
"DeliveryOrderType": String,
"Remark": String
}
}
Propriedades
|
Nome da propriedade |
Tipo |
Obrigatório |
Atualize permitida |
Descrição |
Restrições |
|
ConsumerGroupId |
String |
Sim |
Não |
ID do grupo de consumidores. |
O ID deve ser globalmente único. O valor deve atender aos seguintes requisitos:
|
|
InstanceId |
String |
Sim |
Não |
ID da instância à qual o grupo de consumidores pertence. |
Nenhuma |
|
ConsumeRetryPolicy |
Map |
Sim |
Sim |
Política de repetição de consumo do grupo de consumidores. |
Nenhuma |
|
DeliveryOrderType |
String |
Sim |
Sim |
Ordem de entrega de mensagens do grupo de consumidores. |
Valores válidos:
|
|
Remark |
String |
Não |
Sim |
Observações personalizadas sobre o grupo de consumidores. |
Nenhuma |
Sintaxe de ConsumeRetryPolicy
"ConsumeRetryPolicy": {
"RetryPolicy": String,
"MaxRetryTimes": Integer,
"DeadLetterTargetTopic": String
}
Propriedades de ConsumeRetryPolicy
|
Nome da propriedade |
Tipo |
Obrigatório |
Atualize permitida |
Descrição |
Restrições |
|
RetryPolicy |
String |
Sim |
Sim |
Tipo da política de repetição. |
Valores válidos:
|
|
MaxRetryTimes |
Integer |
Não |
Sim |
Número máximo de tentativas de repetição. |
Nenhuma |
|
DeadLetterTargetTopic |
String |
Não |
Sim |
Tópico de mensagens mortas para o qual o sistema encaminha mensagens com falha. |
Se o consumidor não conseguir processar uma mensagem após atingir o número máximo de tentativas, o sistema encaminhará a mensagem para o tópico de mensagens mortas para recuperação de negócios ou solução de problemas. Para obter mais informações, consulte Repetição de consumo. |
Valores de retorno
Fn::GetAtt
ConsumerGroupId: ID do grupo de consumidores.
InstanceId: ID da instância à qual o grupo de consumidores pertence.
DeliveryOrderType: ordem de entrega de mensagens do grupo de consumidores.
Exemplos
ROSTemplateFormatVersion: '2015-09-01'
Parameters:
ConsumerGroupId:
Type: String
Description: |-
The ID of the consumer group to create. This ID must be globally unique.
The value can be 1 to 60 characters in length and can contain letters (a to z and A to Z), digits (0 to 9), underscores (_), hyphens (-), and percent signs (%).
MinLength: 1
MaxLength: 60
InstanceId:
Type: String
Description: The ID of the instance.
Resources:
ConsumerGroup:
Type: ALIYUN::ROCKETMQ5::ConsumerGroup
Properties:
ConsumerGroupId:
Ref: ConsumerGroupId
InstanceId:
Ref: InstanceId
ConsumeRetryPolicy:
RetryPolicy: DefaultRetryPolicy
MaxRetryTimes: 5
DeliveryOrderType: Concurrently
Outputs:
ConsumerGroupId:
Description: The ID of the consumer group.
Value:
Fn::GetAtt:
- ConsumerGroup
- ConsumerGroupId
InstanceId:
Description: The ID of the instance.
Value:
Fn::GetAtt:
- ConsumerGroup
- InstanceId
DeliveryOrderType:
Description: The delivery order of the consumer group.
Value:
Fn::GetAtt:
- ConsumerGroup
- DeliveryOrderType
{
"ROSTemplateFormatVersion": "2015-09-01",
"Parameters": {
"ConsumerGroupId": {
"Type": "String",
"Description": "The ID of the consumer group to create. This ID must be globally unique.\nThe value can be 1 to 60 characters in length and can contain letters (a to z and A to Z), digits (0 to 9), underscores (_), hyphens (-), and percent signs (%).",
"MinLength": 1,
"MaxLength": 60
},
"InstanceId": {
"Type": "String",
"Description": "The ID of the instance."
}
},
"Resources": {
"ConsumerGroup": {
"Type": "ALIYUN::ROCKETMQ5::ConsumerGroup",
"Properties": {
"ConsumerGroupId": {
"Ref": "ConsumerGroupId"
},
"InstanceId": {
"Ref": "InstanceId"
},
"ConsumeRetryPolicy": {
"RetryPolicy": "DefaultRetryPolicy",
"MaxRetryTimes": 5
},
"DeliveryOrderType": "Concurrently"
}
}
},
"Outputs": {
"ConsumerGroupId": {
"Description": "The ID of the consumer group.",
"Value": {
"Fn::GetAtt": [
"ConsumerGroup",
"ConsumerGroupId"
]
}
},
"InstanceId": {
"Description": "The ID of the instance.",
"Value": {
"Fn::GetAtt": [
"ConsumerGroup",
"InstanceId"
]
}
},
"DeliveryOrderType": {
"Description": "The delivery order of the consumer group.",
"Value": {
"Fn::GetAtt": [
"ConsumerGroup",
"DeliveryOrderType"
]
}
}
}
}