From fb5964af846843951026f86e4fb58d44c61656cc Mon Sep 17 00:00:00 2001
From: zengqiao <zengqiao@didiglobal.com>
Date: Tue, 6 Dec 2022 18:00:29 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85kafka-connect=E7=9B=B8?=
 =?UTF-8?q?=E5=85=B3=E5=8C=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 km-common/pom.xml |  4 ++++
 pom.xml           | 25 ++++++++++++++++++++++++-
 2 files changed, 28 insertions(+), 1 deletion(-)

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>