diff --git a/km-common/pom.xml b/km-common/pom.xml
index e9e66c22..08b90dd7 100644
--- a/km-common/pom.xml
+++ b/km-common/pom.xml
@@ -127,5 +127,9 @@
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka_2.13</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>connect-runtime</artifactId>
+        </dependency>
     </dependencies>
 </project>
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index e1b7bbc3..dfd612aa 100644
--- a/pom.xml
+++ b/pom.xml
@@ -25,8 +25,11 @@
 
         <swagger2.version>2.9.2</swagger2.version>
         <swagger.version>1.5.21</swagger.version>
-        <kafka-clients.version>2.8.1</kafka-clients.version>
+
+        <!-- kafka -->
         <kafka.version>2.8.1</kafka.version>
+        <kafka-clients.version>2.8.1</kafka-clients.version>
+        <kafka-connect-runtime.version>2.8.1</kafka-connect-runtime.version>
 
         <elasticsearch.version>6.6.2</elasticsearch.version>
         <mybatis-plus.version>3.4.2</mybatis-plus.version>
@@ -196,6 +199,7 @@
                 <scope>provided</scope>
             </dependency>
 
+            <!-- kafka -->
             <dependency>
                 <groupId>org.apache.kafka</groupId>
                 <artifactId>kafka-clients</artifactId>
@@ -206,6 +210,25 @@
                 <artifactId>kafka_2.13</artifactId>
                 <version>${kafka.version}</version>
             </dependency>
+            <dependency>
+                <groupId>org.apache.kafka</groupId>
+                <artifactId>connect-runtime</artifactId>
+                <version>${kafka-connect-runtime.version}</version>
+                <exclusions>
+                    <exclusion>
+                        <groupId>org.apache.kafka</groupId>
+                        <artifactId>connect-transforms</artifactId>
+                    </exclusion>
+                    <exclusion>
+                        <groupId>org.apache.kafka</groupId>
+                        <artifactId>connect-api</artifactId>
+                    </exclusion>
+                    <exclusion>
+                        <groupId>org.slf4j</groupId>
+                        <artifactId>slf4j-log4j12</artifactId>
+                    </exclusion>
+                </exclusions>
+            </dependency>
 
             <dependency>
                 <groupId>com.google.guava</groupId>