Skip to content

Latest commit

 

History

History
37 lines (28 loc) · 1.34 KB

README.md

File metadata and controls

37 lines (28 loc) · 1.34 KB
Raw

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.

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

  1. You will need to install Java 1.8+ and Maven
  2. Clone the repository from Github
  3. 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.