diff --git a/flink-sql-runner/pom.xml b/flink-sql-runner/pom.xml
index 1109612..f4fb891 100644
--- a/flink-sql-runner/pom.xml
+++ b/flink-sql-runner/pom.xml
@@ -86,6 +86,13 @@
       <scope>provided</scope>
     </dependency>
 
+    <dependency>
+      <groupId>org.apache.kafka</groupId>
+      <artifactId>kafka-clients</artifactId>
+      <version>${kafka.clients.version}</version>
+      <scope>provided</scope>
+    </dependency>
+
     <!-- Required for Iceberg to work -->
     <dependency>
       <groupId>org.apache.hadoop</groupId>
@@ -501,6 +508,18 @@
               <outputDirectory>${project.build.directory}</outputDirectory>
             </configuration>
           </execution>
+          <execution>
+            <id>copy-kafka-clients</id>
+            <goals>
+              <goal>copy-dependencies</goal>
+            </goals>
+            <phase>prepare-package</phase>
+            <configuration>
+              <includeGroupIds>org.apache.kafka</includeGroupIds>
+              <includeArtifactIds>kafka-clients</includeArtifactIds>
+              <outputDirectory>${project.build.directory}</outputDirectory>
+            </configuration>
+          </execution>
           <execution>
             <id>copy-s3-fs-hadoop</id>
             <goals>
diff --git a/flink-sql-runner/src/main/docker/Dockerfile b/flink-sql-runner/src/main/docker/Dockerfile
index 49ee5f0..3172135 100644
--- a/flink-sql-runner/src/main/docker/Dockerfile
+++ b/flink-sql-runner/src/main/docker/Dockerfile
@@ -19,6 +19,7 @@ FROM apache/flink:${flink-base-image}
 RUN mkdir -p /opt/flink/plugins/flink-sql-runner
 
 COPY aws-msk-iam-auth-*.jar /opt/flink/lib
+COPY kafka-clients-*.jar /opt/flink/lib
 COPY flink-s3-fs-hadoop-*.jar /opt/flink/lib
 COPY hadoop-common-*.jar /opt/flink/lib
 COPY hadoop-hdfs-client-*.jar /opt/flink/lib
diff --git a/pom.xml b/pom.xml
index 7de68f9..22aca1a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -98,6 +98,7 @@
     <auto.service.version>1.1.1</auto.service.version>
     <awaitility.version>4.3.0</awaitility.version>
     <aws-msk-iam-auth.version>2.3.5</aws-msk-iam-auth.version>
+    <kafka.clients.version>3.9.1</kafka.clients.version>
     <commons-exec.version>1.6.0</commons-exec.version>
     <commons-math3.version>3.6.1</commons-math3.version>
     <feign.version>13.5</feign.version>