Amazon Kinesis Data Analytics now supports Apache Flink v1.13

You can now build and run stream processing applications using Apache Flink version 1.13 in Amazon Kinesis Data Analytics. Apache Flink v1.13 provides enhancements to the Table/SQL API, improved interoperability between the Table and DataStream APIs, stateful operations using the Python Datastream API, features to analyze application performance, an exactly-once JDBC sink, and more. With this launch, you also get an Apache Kafka connector that works with AWS IAM authentication when you’re using Amazon Managed Streaming for Apache Kafka(Amazon MSK) as your application’s data source.

Kinesis Data Analytics now supports Apache Flink applications built using JDK 11, Scala 2.12, Python 3.8, and Apache Beam v2.32 Java applications. With Amazon Kinesis Data Analytics Studio, you can interactively query data streams and rapidly develop stream processing applications using an interactive development environment powered by Apache Zeppelin notebooks. Kinesis Data Analytics Studio now supports Apache Flink 1.13 and Apache Zeppelin 0.9.

Kinesis Data Analytics makes it easier to transform and analyze streaming data in real time with Apache Flink. Apache Flink is an open source framework and engine for processing data streams. Kinesis Data Analytics reduces the complexity of building and managing Apache Flink applications. Kinesis Data Analytics for Apache Flink integrates with Amazon MSK, Amazon Kinesis Data Streams, Amazon Opensearch Service, Amazon DynamoDB streams, Amazon Simple Storage Service (Amazon S3), custom integrations, and more using built-in connectors.

You can learn more about Kinesis Data Analytics for Apache Flink in our documentation and what Flink 1.13 offers by visiting the official website.

For Kinesis Data Analytics region availability, refer to the AWS Region Table.