From 0a287ab6e432694f30fa83eab265252f8390ee21 Mon Sep 17 00:00:00 2001 From: toco8 <39761181+toco8@users.noreply.github.com> Date: Mon, 1 Jul 2024 15:29:05 +0900 Subject: [PATCH 1/2] Upgrade dependencies in pom.xml --- README.md | 16 ++--- aws-kinesis-analytics-java-apps.iml | 90 ----------------------------- pom.xml | 34 +++++------ 3 files changed, 25 insertions(+), 115 deletions(-) delete mode 100644 aws-kinesis-analytics-java-apps.iml 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..581c18d 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.18.1 @@ -22,7 +22,7 @@ com.amazonaws aws-java-sdk-bom - 1.11.688 + 1.12.753 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.18 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 From 7ff6dbbb9839e159f0dc0d5dc15c3c0a1ee58592 Mon Sep 17 00:00:00 2001 From: toco8 <39761181+toco8@users.noreply.github.com> Date: Tue, 2 Jul 2024 10:35:19 +0900 Subject: [PATCH 2/2] Update pom.xml --- pom.xml | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pom.xml b/pom.xml index 581c18d..3ec0a36 100644 --- a/pom.xml +++ b/pom.xml @@ -13,7 +13,7 @@ 11 2.12 2.1.0 - 1.18.1 + 1.19.1 @@ -22,7 +22,7 @@ com.amazonaws aws-java-sdk-bom - 1.12.753 + 1.12.754 pom import @@ -40,7 +40,7 @@ org.apache.flink flink-connector-kinesis - 4.3.0-1.18 + 4.3.0-1.19