SelfManagedKafka - Amazon Serverless Application Model
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

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

SelfManagedKafka

描述SelfManagedKafka事件源类型的对象。有关更多信息,请参阅《Amazon Lambda开发者指南》中的 “Amazon Lambda与自管理的 Apache Kafka 一起使用”。

Amazon Serverless Application Model(Amazon SAM) 在设置此事件类型时生成AWS::Lambda::EventSourceMapping资源。

语法

要在Amazon SAM模板中声明此实体,请使用以下语法。

属性

BatchSize

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

类型:整数

必需:否

默认值:100

Amazon CloudFormation兼容性:此属性直接传递给AWS::Lambda::EventSourceMapping资源的BatchSize属性。

最小值1

最大值10000

ConsumerGroupId

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

类型:字符串

必需:否

Amazon CloudFormation兼容性:此属性直接传递给AWS::Lambda::EventSourceMapping资源的SelfManagedKafkaConfiguration属性。

Enabled

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

类型:布尔值

必需:否

Amazon CloudFormation兼容性:此属性直接传递给AWS::Lambda::EventSourceMapping资源的Enabled属性。

FilterCriteria

定义用于确定 Lambda 是否应处理事件的标准的对象。有关更多信息,请参阅Amazon Lambda开发者指南中的Amazon Lambda事件筛选

类型FilterCriteria

必需:否

Amazon CloudFormation兼容性:此属性直接传递给AWS::Lambda::EventSourceMapping资源的FilterCriteria属性。

KafkaBootstrapServers

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

类型:清单

必需:否

Amazon CloudFormation兼容性:此属性是唯一的Amazon SAM,没有Amazon CloudFormation等效属性。

SourceAccessConfigurations

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

有效值BASIC_AUTH | CLIENT_CERTIFICATE_TLS_AUTH | SASL_SCRAM_256_AUTH | SASL_SCRAM_512_AUTH | SERVER_ROOT_CA_CERTIFICATE

类型SourceAccessConfiguration 列表

必需:是

Amazon CloudFormation兼容性:此属性直接传递给AWS::Lambda::EventSourceMapping资源的 SourceAccessConfigurations属性。

Topics

Kafka 主题的名称。

类型:清单

必需:是

Amazon CloudFormation兼容性:此属性直接传递给AWS::Lambda::EventSourceMapping资源的Topics属性。

示例

自行管理的 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