From 8ca513ab365d7fe0e277cf6634c1b43abd0d23aa Mon Sep 17 00:00:00 2001
From: yangjf2019 <highfei2011@outlook.com>
Date: Fri, 10 Jan 2025 17:27:30 +0800
Subject: [PATCH] [e2e] upgrade the flink-sql-connector-kafka version

---
 paimon-e2e-tests/pom.xml | 2 ++
 pom.xml                  | 3 +--
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/paimon-e2e-tests/pom.xml b/paimon-e2e-tests/pom.xml
index 025b15a8bcd3..70f23e36cd2d 100644
--- a/paimon-e2e-tests/pom.xml
+++ b/paimon-e2e-tests/pom.xml
@@ -297,6 +297,7 @@ under the License.
             <properties>
                 <test.flink.main.version>1.19</test.flink.main.version>
                 <test.flink.version>1.19.1</test.flink.version>
+                <test.flink.connector.kafka.version>3.2.0-${test.flink.main.version}</test.flink.connector.kafka.version>
                 <flink.sql.connector.hive>flink-sql-connector-hive-2.3.9_${scala.binary.version}</flink.sql.connector.hive>
             </properties>
         </profile>
@@ -306,6 +307,7 @@ under the License.
             <properties>
                 <test.flink.main.version>1.18</test.flink.main.version>
                 <test.flink.version>1.18.1</test.flink.version>
+                <test.flink.connector.kafka.version>3.0.1-${test.flink.main.version}</test.flink.connector.kafka.version>
                 <flink.sql.connector.hive>flink-sql-connector-hive-2.3.9_${scala.binary.version}</flink.sql.connector.hive>
             </properties>
         </profile>
diff --git a/pom.xml b/pom.xml
index d55694cec76d..d427e05df0ce 100644
--- a/pom.xml
+++ b/pom.xml
@@ -112,8 +112,7 @@ under the License.
         <test.unit.pattern>**/*Test.*</test.unit.pattern>
         <test.flink.main.version>1.20</test.flink.main.version>
         <test.flink.version>1.20.0</test.flink.version>
-        <!-- TODO upgrade after connector releases x-1.19 version -->
-        <test.flink.connector.kafka.version>3.0.1-1.18</test.flink.connector.kafka.version>
+        <test.flink.connector.kafka.version>3.4.0-1.20</test.flink.connector.kafka.version>
         <test.mysql.connector.java.version>8.0.27</test.mysql.connector.java.version>
 
         <!-- spark profile properties-->