This is an automated email from the ASF dual-hosted git repository.
jiabaosun pushed a commit to branch release-3.1
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/release-3.1 by this push:
new b96ea11cc [FLINK-35235][pipeline-connector][kafka] Fix missing
dependencies in the uber jar of Kafka pipeline sink
b96ea11cc is described below
commit b96ea11cc7df6c3d57a155573f29c18bf9d787ae
Author: Kunni <[email protected]>
AuthorDate: Fri Apr 26 17:00:12 2024 +0800
[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 0b0c6f687..5be032a76 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>
