AWS Kinesis Analytics Flink Runtime

This library can be used to access externalised KDA Flink application properties at runtime. See the documentation for a guide on how to configure properties in your KDA application.

AWS Documentation
Issues

Quickstart

Access properties configured via the AWS Console/SDK using:

Properties properties = KinesisAnalyticsRuntime.getApplicationProperties().get("app-group");
String inputStreamName = properties.getProperty("inputStreamName");
String outputStreamName = properties.getProperty("outputStreamName");

Building from Source

You will need to install Java 1.8+ and Maven
Clone the repository from Github
Build using Maven from the project root directory:
1. $ mvn clean install

Flink Version Matrix

This project is compatible with Flink 1.x, there is no guarantee it will support Flink 2.x should it release in the future.

Connector Version	Flink Version	Release Date
1.1.0	1.x	Dec, 2019
1.0.1	1.x	Dec, 2018
1.0.0	1.x	Dec, 2018

License

This library is licensed under the Apache 2.0 License.