发布于: Oct 13, 2021
现在，您可以在 Amazon Kinesis Data Analytics 中使用 Apache Flink 版本 1.13 来构建和运行流式处理应用程序。Apache Flink v1.13 提供了 Table/SQL API 的增强功能、Table 和 DataStream API 之间更高的互操作性、使用 Python Datastream API 的有状态操作、分析应用程序性能的功能、一次性 JDBC 接收器等。此次发布之后，当您使用 Amazon Managed Streaming for Apache Kafka（Amazon MSK）作为应用程序的数据源时，您还可以获得一个可与 AWS IAM 身份验证配合使用的 Apache Kafka 连接器。
Kinesis Data Analytics 现在支持使用 JDK 11、Scala 2.12、Python 3.8 和 Apache Beam v2.32 Java 应用程序构建的 Apache Flink 应用程序。有了 Amazon Kinesis Data Analytics Studio，您便可以交互查询数据流，并使用由 Apache Zeppelin 笔记本提供支持的交互式开发环境迅速开发流处理应用程序。Kinesis Data Analytics Studio 现在支持 Apache Flink 1.13 和 Apache Zepplin 0.9。
Kinesis Data Analytics 可简化使用 Apache Flink 实时转换和分析流数据的过程。Apache Flink 是一种处理数据流的开源框架和引擎。Kinesis Data Analytics 降低了构建、管理 Apache Flink 应用程序的复杂性。Kinesis Data Analytics for Apache Flink 使用内置连接器与 Amazon MSK、Amazon Kinesis Data Streams、Amazon Opensearch Service、Amazon DynamoDB Streams、Amazon Simple Storage Service（Amazon S3）、自定义集成等实现集成。
您可以在我们的文档中了解有关 Kinesis Data Analytics for Apache Flink 的详情，以及访问官方网站，了解 Flink 1.13 提供的功能。
请参阅 AWS 区域列表，了解 Kinesis Data Analytics 的区域可用性。