Amazon Kinesis Data Analytics 现在支持基于 Java 的 Apache Beam 流工作负载

Amazon Kinesis Data Analytics for Apache Flink 现在支持使用 Apache Beam Java SDK 版本 2.23 构建的流应用程序。Apache Beam 是开源统一模型，用于定义可以跨多个执行引擎执行的流和批数据处理应用程序。此版本允许您用 Java 构建 Apache Beam 流应用程序，并使用 Amazon Kinesis Data Analytics 上的 Apache Flink 1.8、本地运行的 Apache Spark 和 Apache 支持的其他执行引擎运行。

Amazon Kinesis Data Analytics 是使用 Apache Flink 实时转换和分析流数据最简单的方法。Apache Flink 是一种处理数据流的开源框架和引擎。Amazon Kinesis Data Analytics 降低了构建、管理 Apache Flink 应用程序的复杂性。Amazon Kinesis Data Analytics for Apache Flink 集成了 Amazon Managed Streaming for Apache Kafka (Amazon MSK)、Amazon Kinesis Data Streams、Amazon Elasticsearch Service、Amazon DynamoDB 流 Amazon S3、自定义集成以及更多正在使用的内置连接器。

您可以在此了解有关 Amazon Kinesis Data Analytics for Apache Flink 的更多信息，并通过流处理分析研讨会构建您自己的 Apache Beam 管道。请参阅 AWS 区域表，了解 Amazon Kinesis Data Analytics 的区域可用性。

请参阅 AWS 区域表，了解 Amazon Kinesis Data Analytics 的区域可用性。