diff --git a/README.md b/README.md index fb928a9..7a82071 100644 --- a/README.md +++ b/README.md @@ -4,16 +4,16 @@ - - --------- -> #### 🚨 August 30, 2023: Amazon Kinesis Data Analytics has been renamed to [Amazon Managed Service for Apache Flink](https://aws.amazon.com/managed-service-apache-flink). - --------- + + +-------- +> #### 🚨 August 30, 2023: Amazon Kinesis Data Analytics has been renamed to [Amazon Managed Service for Apache Flink](https://aws.amazon.com/managed-service-apache-flink). + +--------

This Kinesis Data Analytics for Apache Flink Application reads from a Kinesis Data Stream, Serializes the records and then writes them to an Aurora Postgres Table (every 100 messages). -
+

## 📝 Table of Contents @@ -31,7 +31,7 @@ These instructions will get you a copy of the project up and running on your loc ### Prerequisites ``` -- Java 1.8 +- Java 11 - Apache Flink - A Local or Remote Postgres Database - A Kinesis Data Stream diff --git a/aws-kinesis-analytics-java-apps.iml b/aws-kinesis-analytics-java-apps.iml deleted file mode 100644 index 4d4f84c..0000000 --- a/aws-kinesis-analytics-java-apps.iml +++ /dev/null @@ -1,90 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/pom.xml b/pom.xml index 0a90dc5..3ec0a36 100644 --- a/pom.xml +++ b/pom.xml @@ -10,10 +10,10 @@ jar - 1.8 - 2.11 - 1.1.0 - 1.8.2 + 11 + 2.12 + 2.1.0 + 1.19.1 @@ -22,7 +22,7 @@ com.amazonaws aws-java-sdk-bom - 1.11.688 + 1.12.754 pom import @@ -33,19 +33,19 @@ com.amazonaws aws-kinesisanalytics-runtime - ${kda.version} + 1.2.0 org.apache.flink - flink-connector-kinesis_${scala.binary.version} - ${flink.version} + flink-connector-kinesis + 4.3.0-1.19 org.apache.flink - flink-streaming-java_${scala.binary.version} + flink-streaming-java ${flink.version} provided @@ -65,41 +65,41 @@ org.apache.flink - flink-jdbc_2.11 - ${flink.version} + flink-jdbc_${scala.binary.version} + 1.10.3 org.apache.flink flink-table - 1.8.2 + ${flink.version} pom provided org.apache.flink - flink-table-planner_2.11 + flink-table-planner_${scala.binary.version} ${flink.version} - postgresql + org.postgresql postgresql - 9.1-901-1.jdbc4 + 42.7.3 org.apache.flink - flink-clients_2.11 + flink-clients ${flink.version} provided org.apache.flink - flink-runtime-web_2.11 + flink-runtime-web ${flink.version} provided