Skip to content

Commit df8338e

Browse files
committed
[FLINK-32522][connectors/kafka] Kafka connector should depend on commons-collections instead of inherit from flink
1 parent 910fc5a commit df8338e

File tree

2 files changed

+13
-0
lines changed

2 files changed

+13
-0
lines changed

flink-connector-kafka/pom.xml

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,14 @@ under the License.
7272
<version>${kafka.version}</version>
7373
</dependency>
7474

75+
<!-- Others -->
76+
77+
<dependency>
78+
<groupId>commons-collections</groupId>
79+
<artifactId>commons-collections</artifactId>
80+
<version>3.2.2</version>
81+
</dependency>
82+
7583
<!-- Tests -->
7684

7785
<dependency>

flink-sql-connector-kafka/pom.xml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,7 @@ under the License.
7070
<include>org.apache.flink:flink-connector-base</include>
7171
<include>org.apache.flink:flink-connector-kafka</include>
7272
<include>org.apache.kafka:*</include>
73+
<include>commons-collections:commons-collections</include>
7374
</includes>
7475
</artifactSet>
7576
<filters>
@@ -91,6 +92,10 @@ under the License.
9192
<pattern>org.apache.kafka</pattern>
9293
<shadedPattern>org.apache.flink.kafka.shaded.org.apache.kafka</shadedPattern>
9394
</relocation>
95+
<relocation>
96+
<pattern>org.apache.commons</pattern>
97+
<shadedPattern>org.apache.flink.kafka.shaded.org.apache.commons</shadedPattern>
98+
</relocation>
9499
</relocations>
95100
</configuration>
96101
</execution>

0 commit comments

Comments
 (0)