发布于: Nov 22, 2022
适用于 Apache Flink 的 HAQM Kinesis Data Analytics 现在支持 Apache Flink 版本 1.15。这个新版本包括对 Flink 的精确一次处理语义、Kinesis Data Streams 和 Kinesis Data Firehose 连接器、Python 用户定义的函数、Flink SQL 等方面的改进。该版本还包括 AWS 贡献的功能,即一个新的 Async Sink 框架,它用于简化自定义接收器的创建,以交付处理过的数据。有关功能、改进和错误修复的完整列表,请参阅 Apache Flink 版本 1.15 发行说明。
HAQM Kinesis Data Analytics 可简化使用 Apache Flink 实时转换和分析流数据的过程。Apache Flink 是一种处理数据流的开源框架和引擎。HAQM Kinesis Data Analytics 降低了构建、管理 Apache Flink 应用程序的复杂性。适用于 Apache Flink 的 HAQM Kinesis Data Analytics 集成了 HAQM Managed Streaming for Apache Kafka (HAQM MSK)、HAQM Kinesis Data Streams、HAQM Opensearch Service、HAQM DynamoDB Streams、HAQM S3、自定义集成以及更多正在使用的内置连接器。
2023 年 8 月 30 日:HAQM Kinesis Data Analytics 已更名为适用于 Apache Flink 的亚马逊托管服务。