AWS Lambda 宣布对 Avro 和 Protobuf 格式的 Kafka 事件提供原生支持

发布于: 2025年6月20日

AWS Lambda 现在通过 Apache Kafka 的事件源映射 (ESM) 为 Avro 和 Protobuf 格式的 Kafka 事件提供原生支持，并与 AWS Glue 架构注册表 (GSR)、Confluent 云架构注册表 (CCSR) 和自主管理 Confluent 架构注册表 (SCSR) 集成以进行架构管理。这使您能够使用开源 Kafka 使用者接口来验证架构、筛选事件和处理事件。此外，客户无需编写自定义反序列化代码即可使用 Powertools for AWS Lambda 来处理其 Kafka 事件，从而可以更轻松地使用 AWS Lambda 构建 Kafka 应用程序。

Kafka 客户使用 Avro 和 Protobuf 格式来实现高效的数据存储、快速序列化和反序列化、架构演变支持以及不同编程语言之间的互操作性。在数据进入处理管道之前，他们利用架构注册表来管理、发展和验证架构。此前，客户在使用这些数据格式时，需要在其 Lambda 函数中编写自定义代码，以实现事件的验证、反序列化和筛选。通过今天的发布，Lambda 为 Avro 和 Protobuf 格式提供原生支持，并与 GSR、CCSR 和 SCSR 集成，使客户无需编写自定义代码即可使用这些数据格式处理 Kafka 事件。此外，客户还可以通过事件筛选优化成本，避免不必要的函数调用。

此功能已在所有提供 AWS Lambda Kafka ESM 的 AWS 商业区域全面推出，以色列（特拉维夫）、亚太地区（马来西亚）和加拿大西部（卡尔加里）除外。

要开始使用，请在 ESM API、AWS 管理控制台、AWS CLI、AWS SDK、AWS CloudFormation 和 AWS SAM 中，为您的新 Kafka ESM 或现有 Kafka ESM 提供架构注册表配置。或者，您还可以选择设置筛选规则，在函数调用前丢弃不相关的 Avro 或 Protobuf 格式事件。要使用 Kafka 的开源 ConsumerRecords 接口构建函数，请在 Lambda 函数中添加 Powertools for AWS Lambda 作为依赖项。要了解更多信息，请参阅 Lambda ESM 文档和 AWS Lambda 定价。