发布于: Aug 13, 2020

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

使用 Lambda,您可以轻松地处理 Amazon Kinesis Data Streams 或 Amazon DynamoDB 流中的数据流。现在,您还可以轻松从 Apache Kafka 主题中读取数据,并处理记录批次,一次可为每个分区处理一个批次。当达到最大的批次大小或者负载超过 6MB 时,将调用 Lambda 函数。客户可以通过增加主题中的分区数量来扩展其应用程序的并发性,但需要注意的是,使用多个分区可能会影响消息的次序。

首先,请通过 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 开发人员指南