ALIYUN::ROCKETMQ5::ConsumerGroup

ALIYUN::ROCKETMQ5::ConsumerGroup类型用于创建ROCKETMQ5.0系列的消费者分组。

语法

{
  "Type": "ALIYUN::ROCKETMQ5::ConsumerGroup",
  "Properties": {
    "ConsumerGroupId": String,
    "InstanceId": String,
    "ConsumeRetryPolicy": Map,
    "DeliveryOrderType": String,
    "Remark": String
  }
}

属性

属性名称

类型

必须

允许更新

描述

约束

ConsumerGroupId

String

待创建的消费者分组的ID。

用于标识消费者分组,全局唯一。

取值说明如下:

  • 字符限制:支持字母a~z或A~Z、数字0~9以及下划线(_)、短划线(-)和百分号(%)。

  • 长度限制:1~60个字符。

保留字符限制,请参见使用限制

InstanceId

String

待创建的消费者分组所属的实例ID。

ConsumeRetryPolicy

Map

待创建消费者分组的消费重试策略。

更多信息,请参见 消费重试

DeliveryOrderType

String

待创建消费者分组的投递顺序性。

取值:

  • Concurrently:并发投递。

  • Orderly:顺序投递。

Remark

String

待创建消费者分组的备注信息。

ConsumeRetryPolicy语法

"ConsumeRetryPolicy": {
  "RetryPolicy": String,
  "MaxRetryTimes": Integer
}

ConsumeRetryPolicy属性

属性名称

类型

必须

允许更新

描述

约束

RetryPolicy

String

重试策略类型。

取值:

  • FixedRetryPolicy:固定间隔重试。

  • DefaultRetryPolicy:阶梯退避重试。

更多信息,请参见消费重试

MaxRetryTimes

Integer

最大重试次数。

返回值

Fn::GetAtt

  • ConsumerGroupId:消费者分组的ID。

  • InstanceId:消费者分组所属的实例ID。

  • DeliveryOrderType:待创建消费者分组的投递顺序性。

示例

  • YAML格式

    ROSTemplateFormatVersion: '2015-09-01'
    Parameters:
      ConsumerGroupId:
        Type: String
        Description: |-
          The ID of the consumer group to be created. Used to identify consumer groups, globally unique.
          The value description is as follows:
          Character limitation: supports letters a~z or A-Z, numbers 0-9, underscore (_), dash (-) and percent sign (%).
          Length limit: 1-60 characters.
        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: Delivery sequence of consumer group.
        Value:
          Fn::GetAtt:
            - ConsumerGroup
            - DeliveryOrderType
  • JSON格式

    {
      "ROSTemplateFormatVersion": "2015-09-01",
      "Parameters": {
        "ConsumerGroupId": {
          "Type": "String",
          "Description": "The ID of the consumer group to be created. Used to identify consumer groups, globally unique.\nThe value description is as follows:\nCharacter limitation: supports letters a~z or A-Z, numbers 0-9, underscore (_), dash (-) and percent sign (%).\nLength limit: 1-60 characters.",
          "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": "Delivery sequence of consumer group.",
          "Value": {
            "Fn::GetAtt": [
              "ConsumerGroup",
              "DeliveryOrderType"
            ]
          }
        }
      }
    }