发布于: Aug 13, 2020

(注:本帖已于 2021 年 2 月 23 日更新,以明确功能)

AWS Lambda 现在支持将 Amazon Managed Streaming for Apache Kafka (Amazon MSK) 作为事件源,从而为客户提供更多选择来使用流数据构建无服务器应用程序。客户可以使用 Lambda 函数构建 Apache Kafka 消费者应用程序,无需担心基础设施管理。Amazon MSK 是完全托管服务,可用于轻松构建并运行使用 Apache Kafka 的应用程序来处理流数据。

使用 Lambda,您可以轻松地处理 Amazon Kinesis Data Streams 或 Amazon DynamoDB 流中的数据流。当前,客户也可以构建使用 Amazon MSK 的 Apache Kafka 主题触发的应用程序。消息按批次处理,最多可处理 10,000 条记录,其中可能包含来自一个或多个分区的消息,负载的最大大小为 6MB。一个分区内的消息始终按顺序处理。

首先,请通过 AWS 管理控制台、AWS CLI、AWS SAM 或适用于 Lambda 的 AWS 开发工具包选择 Amazon MSK 主题作为 Lambda 函数的事件源。Amazon MSK 作为 Lambda 事件源已在同时提供 AWS Lambda 和 Amazon MSK 的所有 AWS 区域推出,但 AWS 中国区域和 AWS GovCloud(美国)区域除外。使用此功能不需要支付任何额外费用。您只需为 Apache Kafka 主题触发的 Lambda 调用付费。要了解有关使用 Lambda 构建 Apache Kafka 消费者应用程序的更多信息,请阅读 Lambda 开发人员指南