发布于: Dec 15, 2020
现在，使用 AWS Lambda，客户构建的应用程序可以通过任何基础设施上托管的 Apache Kafka 集群中的消息触发。客户可以将其现有的 Apache Kafka 集群保持原样，并使用 Lambda 快速轻松地构建 Kafka 使用者应用程序，而无需担心预置或管理服务器。
今天，Lambda 支持将 Amazon Managed Streaming for Kafka (Amazon MSK) 作为一个事件源。现在，除了 Amazon MSK 之外，只要 Lambda 可以通过公有 IP 地址或 Amazon VPC 终端节点访问集群，客户还可以构建从他们管理的 Apache Kafka 集群所触发的应用程序。消息按批次处理，最多可处理 10000 条记录，其中可能包含来自一个或多个分区的消息。一个分区内的消息始终按顺序处理。当达到批大小或负载大小达到 6MB 时会调用 Lambda。Lambda 支持使用来自未经身份验证和经过身份验证的集群的消息。
首先，客户可以通过 AWS 管理控制台、AWS CLI 或适用于 Lambda 的 AWS 开发工具包选择 Apache Kafka 作为其 Lambda 函数的事件源。此功能现已在下列 AWS 区域开放：亚太地区（香港）、亚太地区（孟买）、亚太地区（首尔）、亚太地区（新加坡）、亚太地区（悉尼）、亚太地区（东京）、加拿大（中部）、欧洲（法兰克福）、欧洲（爱尔兰）、欧洲（伦敦）、欧洲（巴黎）、欧洲（斯德哥尔摩）、中东（巴林）、南美洲（圣保罗）、美国东部（弗吉尼亚北部）、美国东部（俄亥俄）、美国西部（加利福尼亚北部）、美国西部（俄勒冈）。使用此功能不需要支付任何额外费用。要了解有关使用 Lambda 构建 Apache Kafka 使用者应用程序的更多信息，请阅读 Lambda 开发人员指南和 AWS 计算博客。