From ec643c9dd7365261f3cee620d4d6bd5d042917e0 Mon Sep 17 00:00:00 2001
From: Kunni <lvyanquan.lyq@alibaba-inc.com>
Date: Fri, 26 Apr 2024 16:59:48 +0800
Subject: [PATCH] [FLINK-35235][pipeline-connector][kafka] Fix missing
 dependencies in the uber jar of Kafka pipeline sink

---
 .../flink-cdc-pipeline-connector-kafka/pom.xml         | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/pom.xml b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/pom.xml
index 0b0c6f687c..5be032a76b 100644
--- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/pom.xml
+++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/pom.xml
@@ -83,11 +83,21 @@ limitations under the License.
                         </goals>
                         <configuration>
                             <shadeTestJar>false</shadeTestJar>
+                            <artifactSet>
+                                <includes>
+                                    <include>org.apache.kafka:*</include>
+                                    <include>org.apache.flink:flink-connector-kafka</include>
+                                </includes>
+                            </artifactSet>
                             <relocations>
                                 <relocation>
                                     <pattern>org.apache.kafka</pattern>
                                     <shadedPattern>org.apache.flink.cdc.connectors.kafka.shaded.org.apache.kafka</shadedPattern>
                                 </relocation>
+                                <relocation>
+                                    <pattern>org.apache.flink.connector.kafka</pattern>
+                                    <shadedPattern>org.apache.flink.cdc.connectors.kafka.shaded.org.apache.flink.connector.kafka</shadedPattern>
+                                </relocation>
                             </relocations>
                         </configuration>
                     </execution>