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

Enabled

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

类型:Boolean

必需:否

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