diff --git a/build.gradle.kts b/build.gradle.kts
index dc23bd0..559989c 100644
--- a/build.gradle.kts
+++ b/build.gradle.kts
@@ -85,7 +85,7 @@ configure(subprojects.filter { it.name == "flink-streaming" || it.name == "flink
         implementation("org.apache.flink:flink-runtime-web:$flinkVersion")
 
         // Flink Connectors
-        implementation("org.apache.flink:flink-connector-kafka:3.4.0-1.20")
+        implementation("org.apache.flink:flink-connector-kafka:4.0.1-2.0")
         implementation("org.apache.flink:flink-connector-files:$flinkVersion")
 
         // Confluent
diff --git a/flink-data-generator/build.gradle.kts b/flink-data-generator/build.gradle.kts
index 3d9dd5d..9cd7d05 100644
--- a/flink-data-generator/build.gradle.kts
+++ b/flink-data-generator/build.gradle.kts
@@ -19,7 +19,7 @@ dependencies {
     implementation("org.apache.flink:flink-clients:$flinkVersion")
     
     // Flink Connectors
-    implementation("org.apache.flink:flink-connector-kafka:3.4.0-1.20")
+    implementation("org.apache.flink:flink-connector-kafka:4.0.1-2.0")
     implementation("org.apache.flink:flink-avro:$flinkVersion")
     implementation("org.apache.flink:flink-connector-base:$flinkVersion")
     implementation("org.apache.flink:flink-core:$flinkVersion")