发布于: Sep 29, 2020
借助 Apache Flink Kinesis Data Firehose Producer v2.0.0，Amazon Kinesis Data Analytics 现在支持 Apache Flink 应用程序将数据直接发送到 Amazon Kinesis Data Firehose。新版本添加了对 Amazon Identity and Access Management (IAM) Assume Role 凭证提供程序的支持，包含错误修复，并更新了 Amazon SDK 和其他依赖关系。
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 Streams、Amazon S3、自定义集成等集成。您可以在此处和此处了解有关适用于 Apache Flink 和 SQL 的 Amazon Kinesis Data Analytics 的信息。
要开始使用 Apache Flink Kinesis Data Firehose Producer 的新版本，请参阅 Maven Repository 和 GitHub 存储库。