MSK - AWS Serverless Application Model
语法属性示例
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅中国的 AWS 服务入门。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

MSK

描述 MSK 事件来源类型。

AWS SAM 会生成 ASTA::Lambda::Event源映射 资源。

语法

在你的 AWS 无服务器应用程序模型 (AWS SAM)模板,使用以下语法。

YAML

  StartingPosition: String
  Stream: String
  Topics: List

属性

StartingPosition

在流中开始读取数据的位置。

支持的值 TRIM_HORIZON, LATEST, AT_TIMESTAMP.

类型：字符串

必需: 是

AWS CloudFormation 相容性: 此属性直接传递给 StartingPosition 特性 AWS::Lambda::EventSourceMapping 资源。

Stream

数据流的ARN或流消费者。

类型：字符串

必需: 是

AWS CloudFormation 相容性: 此属性直接传递给 EventSourceArn 特性 AWS::Lambda::EventSourceMapping 资源。

Topics

Kafka主题的名称。

类型:列表

必需: 是

AWS CloudFormation 相容性: 此属性直接传递给 Topics 特性 AWS::Lambda::EventSourceMapping 资源。

示例

现有群集的azonalMSK示例

以下是 MSK 事件来源类型 Amazon MSK 已存在于ASE帐户中的群集。

YAML

Events:
  MSKEvent:
    Type: MSK
    Properties:
      StartingPosition: LATEST
      Stream: arn:aws:kafka:us-east-1:012345678012:cluster/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2
      Topics:
        - MyTopic

相同模板中声明的群集的alirocumabMSK示例

以下是 MSK 事件来源类型 Amazon MSK 在同一模板文件中声明的群集。

YAML

Events:
  MSKEvent:
    Type: MSK
    Properties:
      StartingPosition: LATEST
      Stream:
        Ref: MyMskCluster   # This must be the name of an MSK cluster declared in the same template file
      Topics:
        - MyTopic