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

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

SelfManagedKafka

描述一个SelfManagedKafka事件源类型。有关更多信息，请参阅 。使用Amazon Lambda使用自行管理的 Apache Kafka中的Amazon Lambda开发人员指南.

Amazon SAM生成AWS::Lambda::EventSourceMapping设置此事件类型时的资源。

语法

要在中声明此实体Amazon Serverless Application Model(Amazon SAM) 模板，请使用以下语法。

属性

BatchSize

Lambda 从流中提取并发送到函数的每个批处理中的最大记录数。

类型：整数

必需：否

默认值：100

Amazon CloudFormation兼容性：此属性将直接传递给BatchSize一个的财产AWS::Lambda::EventSourceMapping资源。

最小值：1

最大值：10000

ConsumerGroupId

一个字符串，用于配置如何从 Kafka 主题中读取事件。

类型：字符串

必需：否

Amazon CloudFormation兼容性：此属性将直接传递给SelfManagedKafkaConfiguration一个的财产AWS::Lambda::EventSourceMapping资源。

Enabled

禁用事件源映射以暂停轮询和调用。

类型：布尔值

必需：否

Amazon CloudFormation兼容性：此属性将直接传递给Enabled一个的财产AWS::Lambda::EventSourceMapping资源。

KafkaBootstrapServers

适用于Kafka代理的 Bootstrap 服务器列表。例如，包括端口broker.example.com:xxxx

类型：List

必需：否

Amazon CloudFormation兼容性：此属性对是唯一的Amazon SAM而且没有Amazon CloudFormation等效函数。

SourceAccessConfigurations

用于保护与定义事件源的身份验证协议数组 VPC 组件或虚拟化主机。

类型：SourceAccessConfiguration

必需：是

Amazon CloudFormation兼容性：此属性将直接传递给SourceAccessConfigurations一个的财产AWS::Lambda::EventSourceMapping资源。

Topics

Kafka 主题的名称。

类型：List

必需：是

Amazon CloudFormation兼容性：此属性将直接传递给Topics一个的财产AWS::Lambda::EventSourceMapping资源。

示例

自行管理的 Kafka 事件源

以下是的示例SelfManagedKafka事件源类型。

YAML

Events:
  SelfManagedKafkaEvent:
    Type: SelfManagedKafka
    Properties:
      BatchSize: 1000
      Enabled: true
      KafkaBootstrapServers:
        - abc.xyz.com:xxxx
      SourceAccessConfigurations: 
        -  Type: BASIC_AUTH
           URI: arn:aws:secretsmanager:us-west-2:123456789012:secret:my-path/my-secret-name-1a2b3c
      Topics:
        - MyKafkaTopic