发布于: Oct 7, 2020

Apache Flink Kinesis 使用器现在支持将增强型扇出 (EFO) 和 HTTP/2 数据检索 API 用于 Amazon Kinesis Data Streams。EFO 可为每个使用器提供高达 2MB/sec 的读取吞吐量以使 Amazon Kinesis Data Streams 使用器进行扩展。HTTP/2 数据检索 API 可将创建器至使用器的数据传输延迟减少至 70 毫秒或更少。这两种功能结合,允许您利用来自 Amazon Kinesis Data Streams 的专用吞吐量构建低延迟 Apache Flink 应用程序。

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 Elasticsearch Service、Amazon DynamoDB 流、Amazon S3、自定义集成以及更多正在使用的内置连接器。您可以在此处了解有关适用于 Apache Flink 的 Amazon Kinesis Data Analytics 的更多信息。

要开始将 Apache Flink Kinesis Data Streams 连接器用于 EFO,请参阅适用于 Apache Flink 1.8 版的 Maven 存储库 和 GitHub 存储库

有关推出 Amazon Kinesis Data Analytics 的区域的列表,请参阅 AWS 区域表。