This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch release-3.2
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/release-3.2 by this push:
new d7d7f42c0 [FLINK-36211][pipeline-connector/kafka] Shade
org.apache.flink.streaming.connectors.kafka to avoid conflict with
flink-connector-kafka jar
d7d7f42c0 is described below
commit d7d7f42c0b686cbea79ca874b8fef2e38d5c9e43
Author: Kunni <lvyanquan....@alibaba-inc.com>
AuthorDate: Mon Nov 18 17:05:08 2024 +0800
[FLINK-36211][pipeline-connector/kafka] Shade
org.apache.flink.streaming.connectors.kafka to avoid conflict with
flink-connector-kafka jar
This closes #3697
---
.../flink-cdc-pipeline-connector-kafka/pom.xml | 4 ++++
1 file changed, 4 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 2614f594f..841271b4b 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
@@ -106,6 +106,10 @@ limitations under the License.
<pattern>org.apache.flink.connector.kafka</pattern>
<shadedPattern>org.apache.flink.cdc.connectors.kafka.shaded.org.apache.flink.connector.kafka</shadedPattern>
</relocation>
+ <relocation>
+
<pattern>org.apache.flink.streaming.connectors.kafka</pattern>
+
<shadedPattern>org.apache.flink.cdc.connectors.kafka.shaded.org.apache.flink.streaming.connectors.kafka</shadedPattern>
+ </relocation>
</relocations>
</configuration>
</execution>
