发布于: Oct 27, 2020
适用于 Apache Flink 的 Amazon Kinesis Data Analytics 现在支持使用 Apache Beam Java 软件开发工具包 2.23 版构建的流式应用程序。Apache Beam 是一种开源的统一模型，用于定义可跨多个执行引擎执行的流式和批数据处理应用程序。使用此版本，您可以在 Java 中构建 Apache Beam 流式应用程序，并使用 Apache Flink 1.8 在 Amazon Kinesis Data Analytics、运行在本地的 Apache Spark 以及 Apache 支持的其他执行引擎上运行这些应用程序。
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 的 Amazon Kinesis Data Analytics，以及通过流分析研讨会构建您自己的 Apache Beam 管道。要详细了解 Apache Flink 和 Apache Beam，您可以访问其各自的官方网站。