发布于: Nov 22, 2022

适用于 Apache Flink 的 Amazon Kinesis Data Analytics 现在支持 Apache Flink 版本 1.15。这个新版本包括对 Flink 的精确一次处理语义、Kinesis Data Streams 和 Kinesis Data Firehose 连接器、Python 用户定义的函数、Flink SQL 等方面的改进。该版本还包括 AWS 贡献的功能,即一个新的 Async Sink 框架,它用于简化自定义接收器的创建,以交付处理过的数据。有关功能、改进和错误修复的完整列表,请参阅 Apache Flink 版本 1.15 发行说明。  

Amazon Kinesis Data Analytics 可简化使用 Apache Flink 实时转换和分析流数据的过程。Apache Flink 是一种处理数据流的开源框架和引擎。Amazon Kinesis Data Analytics 降低了构建、管理 Apache Flink 应用程序的复杂性。适用于 Apache Flink 的 Amazon Kinesis Data Analytics 集成了 Amazon Managed Streaming for Apache Kafka (Amazon MSK)、Amazon Kinesis Data Streams、Amazon Opensearch Service、Amazon DynamoDB Streams、Amazon S3、自定义集成以及更多正在使用的内置连接器。

您可以在我们的文档中了解有关适用于 Apache Flink 的 Amazon Kinesis Data Analytics 的更多信息,以及访问官方网站,了解 Apache Flink 1.15 提供的功能。请参阅 AWS 区域表,了解 Kinesis Data Analytics 的区域可用性。

2023 年 8 月 30 日:Amazon Kinesis Data Analytics 已更名为适用于 Apache Flink 的亚马逊托管服务。