[FLINK-36211][pipeline-connector/kafka] shade org.apache.flink.stream…

…ing.connectors.kafka to avoid conflict with flink-connector-kafka jar. (#3595)
apache · Oct 23, 2024 · f24399c · f24399c
1 parent ecce759
commit f24399c
Showing 1 changed file with 4 additions and 0 deletions.
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
@@ -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>