AWS Kinesis Analytics Java Flink Runtime

This library contains the Kinesis Analytics Java stream processing runtime configuration classes.

License	The Apache License, Version 2.0
Categories	AWS Container PaaS Providers
GroupId	com.amazonaws
ArtifactId	aws-kinesisanalytics-runtime
Last Version	1.2.0
Release Date	Oct 5, 2020
Type	jar
Description	AWS Kinesis Analytics Java Flink Runtime This library contains the Kinesis Analytics Java stream processing runtime configuration classes.
Project URL	https://aws.amazon.com/kinesis/data-analytics/
Source Code Management	https://github.com/aws/aws-kinesisanalytics-runtime/tree/master

Download aws-kinesisanalytics-runtime

Filename	Size
aws-kinesisanalytics-runtime-1.2.0.pom
aws-kinesisanalytics-runtime-1.2.0.jar	8 KB
aws-kinesisanalytics-runtime-1.2.0-sources.jar	8 KB
aws-kinesisanalytics-runtime-1.2.0-javadoc.jar	48 KB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/com.amazonaws/aws-kinesisanalytics-runtime/ -->
<dependency>
    <groupId>com.amazonaws</groupId>
    <artifactId>aws-kinesisanalytics-runtime</artifactId>
    <version>1.2.0</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/com.amazonaws/aws-kinesisanalytics-runtime/
implementation 'com.amazonaws:aws-kinesisanalytics-runtime:1.2.0'

Gradle Kotlin

// https://jarcasting.com/artifacts/com.amazonaws/aws-kinesisanalytics-runtime/
implementation ("com.amazonaws:aws-kinesisanalytics-runtime:1.2.0")

Apache Buildr

'com.amazonaws:aws-kinesisanalytics-runtime:jar:1.2.0'

Apache Ivy

<dependency org="com.amazonaws" name="aws-kinesisanalytics-runtime" rev="1.2.0">
  <artifact name="aws-kinesisanalytics-runtime" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='com.amazonaws', module='aws-kinesisanalytics-runtime', version='1.2.0')
)

Scala SBT

libraryDependencies += "com.amazonaws" % "aws-kinesisanalytics-runtime" % "1.2.0"

Leiningen

[com.amazonaws/aws-kinesisanalytics-runtime "1.2.0"]

Dependencies

provided (2)

Group / Artifact	Type	Version
org.apache.flink : flink-core	jar	1.8.3
org.apache.flink : flink-shaded-jackson	jar	2.7.9-4.0

test (2)

Group / Artifact	Type	Version
junit : junit	jar	4.13
org.assertj : assertj-core	jar	3.16.1

Project Modules

There are no modules declared in this project.

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

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.

Amazon Web Services

Versions

Version
1.2.0 Oct 5, 2020
1.1.0 Dec 14, 2019
1.0.1 Dec 12, 2018
1.0.0 Nov 25, 2018