发布于: Sep 15, 2020

使用适用于 Apache Flink 的 Amazon Kinesis Data Firehose Producer 第 2.0.0 版本,Amazon Kinesis Data Analytics 现在允许 Apache Flink 应用程序直接将数据发送至 Amazon Kinesis Data Firehose。新版本增加了对 AWS Identity and Access Management (IAM) Assume Role 凭证提供程序的支持,包括错误修复,以及更新 AWS 开发工具包和其他依赖关系。 

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 和 SQL 应用程序的 Amazon Kinesis Data Analytics。

要开始使用新版本的适用于 Apache Flink 的 Amazon Kinesis Data Firehose Producer,请参阅 Maven 存储库 和 GitHub 存储库

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