本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
MSK
描述 MSK
事件源类型的对象。有关更多信息,请参阅 AWS LambdaAmazon MSK 中的将 与 AWS Lambda Developer Guide 一起使用。
AWS SAM 在设置此事件类型时生成 AWS::Lambda::EventSourceMapping 资源。
语法
在您的 中声明此实体 AWS 无服务器应用程序模型 (AWS SAM) 模板时,请使用以下语法。
YAML
StartingPosition:
String
Stream:String
Topics:List
属性
-
StartingPosition
-
在流中开始读取数据的位置。
有效值:
TRIM_HORIZON
或者LATEST
类型:字符串
必需: 是
兼容性AWS CloudFormation:此属性直接传递给
StartingPosition
资源的AWS::Lambda::EventSourceMapping
属性。 -
Stream
-
数据流或流使用者的 ARN。
类型:字符串
必需: 是
兼容性AWS CloudFormation:此属性直接传递给
EventSourceArn
资源的AWS::Lambda::EventSourceMapping
属性。 -
Topics
-
Kafka 主题的名称。
类型:列表
必需: 是
兼容性AWS CloudFormation:此属性直接传递给
Topics
资源的AWS::Lambda::EventSourceMapping
属性。
示例
现有集群的 Amazon MSK 示例
以下是 AWS 账户中已存在的 MSK
集群的 Amazon MSK 事件源类型示例。
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
在同一模板中声明的集群的 Amazon MSK 示例
以下是在同一模板文件中声明的 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