本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
SelfManagedKafka
描述SelfManagedKafka事件源类型的对象。有关更多信息,请参阅《Amazon Lambda开发者指南》中的 “Amazon Lambda与自管理的 Apache Kafka 一起使用”。
Amazon Serverless Application Model(Amazon SAM) 在设置此事件类型时生成AWS::Lambda::EventSourceMapping资源。
语法
要在Amazon SAM模板中声明此实体,请使用以下语法。
YAML
BatchSize:IntegerConsumerGroupId:StringEnabled:BooleanFilterCriteria:FilterCriteriaKafkaBootstrapServers:ListSourceAccessConfigurations:SourceAccessConfigurationsTopics:List
属性
-
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事件筛选。
必需:否
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