You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/01/04 11:10:40 UTC
[flink] 02/02: [FLINK-11026][kafka][SQL] Rework kafka sql-client
jar creation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit b6237688b27ee2ca2cdda49820c5d2d541e12bbc
Author: zentol <ch...@apache.org>
AuthorDate: Tue Dec 18 13:40:03 2018 +0100
[FLINK-11026][kafka][SQL] Rework kafka sql-client jar creation
---
docs/dev/table/connect.md | 8 +-
.../flink-connector-kafka-0.10/pom.xml | 53 -------------
.../flink-connector-kafka-0.11/pom.xml | 54 -------------
flink-connectors/flink-connector-kafka-0.9/pom.xml | 50 ------------
flink-connectors/flink-connector-kafka/pom.xml | 52 -------------
.../flink-sql-connector-kafka-0.10/pom.xml | 87 +++++++++++++++++++++
.../flink-sql-connector-kafka-0.11/pom.xml | 88 ++++++++++++++++++++++
.../flink-sql-connector-kafka-0.9/pom.xml | 86 +++++++++++++++++++++
flink-connectors/flink-sql-connector-kafka/pom.xml | 87 +++++++++++++++++++++
flink-connectors/pom.xml | 4 +
.../flink-sql-client-test/pom.xml | 21 ++----
11 files changed, 363 insertions(+), 227 deletions(-)
diff --git a/docs/dev/table/connect.md b/docs/dev/table/connect.md
index c05102c..27c6920 100644
--- a/docs/dev/table/connect.md
+++ b/docs/dev/table/connect.md
@@ -45,10 +45,10 @@ The following tables list all available connectors and formats. Their mutual com
| Filesystem | | Built-in | Built-in |
| Elasticsearch | 6 | `flink-connector-elasticsearch6` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch6{{site.scala_version_suffix}}/{{site.version}}/flink-sql-connector-elasticsearch6{{site.scala_version_suffix}}-{{site.version}}.jar) |
| Apache Kafka | 0.8 | `flink-connector-kafka-0.8` | Not available |
-| Apache Kafka | 0.9 | `flink-connector-kafka-0.9` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-connector-kafka-0.9{{site.scala_version_suffix}}/{{site.version}}/flink-connector-kafka-0.9{{site.scala_version_suffix}}-{{site.version}}-sql-jar.jar) |
-| Apache Kafka | 0.10 | `flink-connector-kafka-0.10` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-connector-kafka-0.10{{site.scala_version_suffix}}/{{site.version}}/flink-connector-kafka-0.10{{site.scala_version_suffix}}-{{site.version}}-sql-jar.jar) |
-| Apache Kafka | 0.11 | `flink-connector-kafka-0.11` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-connector-kafka-0.11{{site.scala_version_suffix}}/{{site.version}}/flink-connector-kafka-0.11{{site.scala_version_suffix}}-{{site.version}}-sql-jar.jar) |
-| Apache Kafka | 0.11+ (`universal`) | `flink-connector-kafka` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-connector-kafka{{site.scala_version_suffix}}/{{site.version}}/flink-connector-kafka{{site.scala_version_suffix}}-{{site.version}}-sql-jar.jar) |
+| Apache Kafka | 0.9 | `flink-connector-kafka-0.9` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-sql-connector-kafka-0.9{{site.scala_version_suffix}}/{{site.version}}/flink-sql-connector-kafka-0.9{{site.scala_version_suffix}}-{{site.version}}.jar) |
+| Apache Kafka | 0.10 | `flink-connector-kafka-0.10` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-sql-connector-kafka-0.10{{site.scala_version_suffix}}/{{site.version}}/flink-sql-connector-kafka-0.10{{site.scala_version_suffix}}-{{site.version}}.jar) |
+| Apache Kafka | 0.11 | `flink-connector-kafka-0.11` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-sql-connector-kafka-0.11{{site.scala_version_suffix}}/{{site.version}}/flink-sql-connector-kafka-0.11{{site.scala_version_suffix}}-{{site.version}}.jar) |
+| Apache Kafka | 0.11+ (`universal`) | `flink-connector-kafka` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-sql-connector-kafka{{site.scala_version_suffix}}/{{site.version}}/flink-sql-connector-kafka{{site.scala_version_suffix}}-{{site.version}}.jar) |
### Formats
diff --git a/flink-connectors/flink-connector-kafka-0.10/pom.xml b/flink-connectors/flink-connector-kafka-0.10/pom.xml
index 75ced03..8871d79 100644
--- a/flink-connectors/flink-connector-kafka-0.10/pom.xml
+++ b/flink-connectors/flink-connector-kafka-0.10/pom.xml
@@ -174,59 +174,6 @@ under the License.
</dependencies>
- <profiles>
- <!-- Create SQL Client uber jars by default -->
- <profile>
- <id>sql-jars</id>
- <activation>
- <property>
- <name>!skipSqlJars</name>
- </property>
- </activation>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-shade-plugin</artifactId>
- <executions>
- <execution>
- <phase>package</phase>
- <goals>
- <goal>shade</goal>
- </goals>
- <configuration>
- <shadedArtifactAttached>true</shadedArtifactAttached>
- <shadedClassifierName>sql-jar</shadedClassifierName>
- <artifactSet>
- <includes combine.children="append">
- <include>org.apache.kafka:*</include>
- <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include>
- <include>org.apache.flink:flink-connector-kafka-0.9_${scala.binary.version}</include>
- </includes>
- </artifactSet>
- <filters>
- <filter>
- <artifact>*:*</artifact>
- <excludes>
- <exclude>kafka/kafka-version.properties</exclude>
- </excludes>
- </filter>
- </filters>
- <relocations>
- <relocation>
- <pattern>org.apache.kafka</pattern>
- <shadedPattern>org.apache.flink.kafka010.shaded.org.apache.kafka</shadedPattern>
- </relocation>
- </relocations>
- </configuration>
- </execution>
- </executions>
- </plugin>
- </plugins>
- </build>
- </profile>
- </profiles>
-
<build>
<plugins>
<plugin>
diff --git a/flink-connectors/flink-connector-kafka-0.11/pom.xml b/flink-connectors/flink-connector-kafka-0.11/pom.xml
index cf25ee9..d44ab8d 100644
--- a/flink-connectors/flink-connector-kafka-0.11/pom.xml
+++ b/flink-connectors/flink-connector-kafka-0.11/pom.xml
@@ -182,60 +182,6 @@ under the License.
</dependencies>
- <profiles>
- <!-- Create SQL Client uber jars by default -->
- <profile>
- <id>sql-jars</id>
- <activation>
- <property>
- <name>!skipSqlJars</name>
- </property>
- </activation>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-shade-plugin</artifactId>
- <executions>
- <execution>
- <phase>package</phase>
- <goals>
- <goal>shade</goal>
- </goals>
- <configuration>
- <shadedArtifactAttached>true</shadedArtifactAttached>
- <shadedClassifierName>sql-jar</shadedClassifierName>
- <artifactSet>
- <includes combine.children="append">
- <include>org.apache.kafka:*</include>
- <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include>
- <include>org.apache.flink:flink-connector-kafka-0.9_${scala.binary.version}</include>
- <include>org.apache.flink:flink-connector-kafka-0.10_${scala.binary.version}</include>
- </includes>
- </artifactSet>
- <filters>
- <filter>
- <artifact>*:*</artifact>
- <excludes>
- <exclude>kafka/kafka-version.properties</exclude>
- </excludes>
- </filter>
- </filters>
- <relocations>
- <relocation>
- <pattern>org.apache.kafka</pattern>
- <shadedPattern>org.apache.flink.kafka011.shaded.org.apache.kafka</shadedPattern>
- </relocation>
- </relocations>
- </configuration>
- </execution>
- </executions>
- </plugin>
- </plugins>
- </build>
- </profile>
- </profiles>
-
<build>
<plugins>
<plugin>
diff --git a/flink-connectors/flink-connector-kafka-0.9/pom.xml b/flink-connectors/flink-connector-kafka-0.9/pom.xml
index 2881291..3ac8554 100644
--- a/flink-connectors/flink-connector-kafka-0.9/pom.xml
+++ b/flink-connectors/flink-connector-kafka-0.9/pom.xml
@@ -174,56 +174,6 @@ under the License.
</dependency>
</dependencies>
</profile>
-
- <!-- Create SQL Client uber jars by default -->
- <profile>
- <id>sql-jars</id>
- <activation>
- <property>
- <name>!skipSqlJars</name>
- </property>
- </activation>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-shade-plugin</artifactId>
- <executions>
- <execution>
- <phase>package</phase>
- <goals>
- <goal>shade</goal>
- </goals>
- <configuration>
- <shadedArtifactAttached>true</shadedArtifactAttached>
- <shadedClassifierName>sql-jar</shadedClassifierName>
- <artifactSet>
- <includes combine.children="append">
- <include>org.apache.kafka:*</include>
- <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include>
- </includes>
- </artifactSet>
- <filters>
- <filter>
- <artifact>*:*</artifact>
- <excludes>
- <exclude>kafka/kafka-version.properties</exclude>
- </excludes>
- </filter>
- </filters>
- <relocations>
- <relocation>
- <pattern>org.apache.kafka</pattern>
- <shadedPattern>org.apache.flink.kafka09.shaded.org.apache.kafka</shadedPattern>
- </relocation>
- </relocations>
- </configuration>
- </execution>
- </executions>
- </plugin>
- </plugins>
- </build>
- </profile>
</profiles>
<build>
diff --git a/flink-connectors/flink-connector-kafka/pom.xml b/flink-connectors/flink-connector-kafka/pom.xml
index 53760089..30f6a5f 100644
--- a/flink-connectors/flink-connector-kafka/pom.xml
+++ b/flink-connectors/flink-connector-kafka/pom.xml
@@ -165,58 +165,6 @@ under the License.
</dependencies>
- <profiles>
- <!-- Create SQL Client uber jars by default -->
- <profile>
- <id>sql-jars</id>
- <activation>
- <property>
- <name>!skipSqlJars</name>
- </property>
- </activation>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-shade-plugin</artifactId>
- <executions>
- <execution>
- <phase>package</phase>
- <goals>
- <goal>shade</goal>
- </goals>
- <configuration>
- <shadedArtifactAttached>true</shadedArtifactAttached>
- <shadedClassifierName>sql-jar</shadedClassifierName>
- <artifactSet>
- <includes combine.children="append">
- <include>org.apache.kafka:*</include>
- <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include>
- </includes>
- </artifactSet>
- <filters>
- <filter>
- <artifact>*:*</artifact>
- <excludes>
- <exclude>kafka/kafka-version.properties</exclude>
- </excludes>
- </filter>
- </filters>
- <relocations>
- <relocation>
- <pattern>org.apache.kafka</pattern>
- <shadedPattern>org.apache.flink.kafka.shaded.org.apache.kafka</shadedPattern>
- </relocation>
- </relocations>
- </configuration>
- </execution>
- </executions>
- </plugin>
- </plugins>
- </build>
- </profile>
- </profiles>
-
<build>
<plugins>
<plugin>
diff --git a/flink-connectors/flink-sql-connector-kafka-0.10/pom.xml b/flink-connectors/flink-sql-connector-kafka-0.10/pom.xml
new file mode 100644
index 0000000..0602757
--- /dev/null
+++ b/flink-connectors/flink-sql-connector-kafka-0.10/pom.xml
@@ -0,0 +1,87 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements. See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership. The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied. See the License for the
+specific language governing permissions and limitations
+under the License.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-connectors</artifactId>
+ <version>1.8-SNAPSHOT</version>
+ <relativePath>..</relativePath>
+ </parent>
+
+ <artifactId>flink-sql-connector-kafka-0.10_${scala.binary.version}</artifactId>
+ <name>flink-sql-connector-kafka-0.10</name>
+
+ <packaging>jar</packaging>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-connector-kafka-0.10_${scala.binary.version}</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-shade-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>shade-flink</id>
+ <phase>package</phase>
+ <goals>
+ <goal>shade</goal>
+ </goals>
+ <configuration>
+ <artifactSet>
+ <includes>
+ <include>org.apache.kafka:*</include>
+ <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include>
+ <include>org.apache.flink:flink-connector-kafka-0.9_${scala.binary.version}</include>
+ <include>org.apache.flink:flink-connector-kafka-0.10_${scala.binary.version}</include>
+ </includes>
+ </artifactSet>
+ <filters>
+ <filter>
+ <artifact>*:*</artifact>
+ <excludes>
+ <exclude>kafka/kafka-version.properties</exclude>
+ </excludes>
+ </filter>
+ </filters>
+ <relocations>
+ <relocation>
+ <pattern>org.apache.kafka</pattern>
+ <shadedPattern>org.apache.flink.kafka010.shaded.org.apache.kafka</shadedPattern>
+ </relocation>
+ </relocations>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git a/flink-connectors/flink-sql-connector-kafka-0.11/pom.xml b/flink-connectors/flink-sql-connector-kafka-0.11/pom.xml
new file mode 100644
index 0000000..4b031a1
--- /dev/null
+++ b/flink-connectors/flink-sql-connector-kafka-0.11/pom.xml
@@ -0,0 +1,88 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements. See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership. The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied. See the License for the
+specific language governing permissions and limitations
+under the License.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-connectors</artifactId>
+ <version>1.8-SNAPSHOT</version>
+ <relativePath>..</relativePath>
+ </parent>
+
+ <artifactId>flink-sql-connector-kafka-0.11_${scala.binary.version}</artifactId>
+ <name>flink-sql-connector-kafka-0.11</name>
+
+ <packaging>jar</packaging>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-connector-kafka-0.11_${scala.binary.version}</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-shade-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>shade-flink</id>
+ <phase>package</phase>
+ <goals>
+ <goal>shade</goal>
+ </goals>
+ <configuration>
+ <artifactSet>
+ <includes>
+ <include>org.apache.kafka:*</include>
+ <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include>
+ <include>org.apache.flink:flink-connector-kafka-0.9_${scala.binary.version}</include>
+ <include>org.apache.flink:flink-connector-kafka-0.10_${scala.binary.version}</include>
+ <include>org.apache.flink:flink-connector-kafka-0.11_${scala.binary.version}</include>
+ </includes>
+ </artifactSet>
+ <filters>
+ <filter>
+ <artifact>*:*</artifact>
+ <excludes>
+ <exclude>kafka/kafka-version.properties</exclude>
+ </excludes>
+ </filter>
+ </filters>
+ <relocations>
+ <relocation>
+ <pattern>org.apache.kafka</pattern>
+ <shadedPattern>org.apache.flink.kafka011.shaded.org.apache.kafka</shadedPattern>
+ </relocation>
+ </relocations>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git a/flink-connectors/flink-sql-connector-kafka-0.9/pom.xml b/flink-connectors/flink-sql-connector-kafka-0.9/pom.xml
new file mode 100644
index 0000000..4668ee5
--- /dev/null
+++ b/flink-connectors/flink-sql-connector-kafka-0.9/pom.xml
@@ -0,0 +1,86 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements. See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership. The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied. See the License for the
+specific language governing permissions and limitations
+under the License.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-connectors</artifactId>
+ <version>1.8-SNAPSHOT</version>
+ <relativePath>..</relativePath>
+ </parent>
+
+ <artifactId>flink-sql-connector-kafka-0.9_${scala.binary.version}</artifactId>
+ <name>flink-sql-connector-kafka-0.9</name>
+
+ <packaging>jar</packaging>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-connector-kafka-0.9_${scala.binary.version}</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-shade-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>shade-flink</id>
+ <phase>package</phase>
+ <goals>
+ <goal>shade</goal>
+ </goals>
+ <configuration>
+ <artifactSet>
+ <includes>
+ <include>org.apache.kafka:*</include>
+ <include>org.apache.flink:flink-connector-kafka-0.9_${scala.binary.version}</include>
+ <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include>
+ </includes>
+ </artifactSet>
+ <filters>
+ <filter>
+ <artifact>*:*</artifact>
+ <excludes>
+ <exclude>kafka/kafka-version.properties</exclude>
+ </excludes>
+ </filter>
+ </filters>
+ <relocations>
+ <relocation>
+ <pattern>org.apache.kafka</pattern>
+ <shadedPattern>org.apache.flink.kafka09.shaded.org.apache.kafka</shadedPattern>
+ </relocation>
+ </relocations>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git a/flink-connectors/flink-sql-connector-kafka/pom.xml b/flink-connectors/flink-sql-connector-kafka/pom.xml
new file mode 100644
index 0000000..8a2609e
--- /dev/null
+++ b/flink-connectors/flink-sql-connector-kafka/pom.xml
@@ -0,0 +1,87 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements. See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership. The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied. See the License for the
+specific language governing permissions and limitations
+under the License.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <artifactId>flink-connectors</artifactId>
+ <groupId>org.apache.flink</groupId>
+ <version>1.8-SNAPSHOT</version>
+ <relativePath>..</relativePath>
+ </parent>
+
+ <artifactId>flink-sql-connector-kafka_${scala.binary.version}</artifactId>
+ <name>flink-sql-connector-kafka</name>
+
+ <packaging>jar</packaging>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-shade-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>shade-flink</id>
+ <phase>package</phase>
+ <goals>
+ <goal>shade</goal>
+ </goals>
+ <configuration>
+ <shadeTestJar>false</shadeTestJar>
+ <artifactSet>
+ <includes>
+ <include>org.apache.kafka:*</include>
+ <include>org.apache.flink:flink-connector-kafka_${scala.binary.version}</include>
+ <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include>
+ </includes>
+ </artifactSet>
+ <filters>
+ <filter>
+ <artifact>*:*</artifact>
+ <excludes>
+ <exclude>kafka/kafka-version.properties</exclude>
+ </excludes>
+ </filter>
+ </filters>
+ <relocations>
+ <relocation>
+ <pattern>org.apache.kafka</pattern>
+ <shadedPattern>org.apache.flink.kafka.shaded.org.apache.kafka</shadedPattern>
+ </relocation>
+ </relocations>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git a/flink-connectors/pom.xml b/flink-connectors/pom.xml
index 807f03d..80b0c25 100644
--- a/flink-connectors/pom.xml
+++ b/flink-connectors/pom.xml
@@ -93,6 +93,10 @@ under the License.
</activation>
<modules>
<module>flink-sql-connector-elasticsearch6</module>
+ <module>flink-sql-connector-kafka-0.9</module>
+ <module>flink-sql-connector-kafka-0.10</module>
+ <module>flink-sql-connector-kafka-0.11</module>
+ <module>flink-sql-connector-kafka</module>
</modules>
</profile>
diff --git a/flink-end-to-end-tests/flink-sql-client-test/pom.xml b/flink-end-to-end-tests/flink-sql-client-test/pom.xml
index 3b04f8f..ad54b3a 100644
--- a/flink-end-to-end-tests/flink-sql-client-test/pom.xml
+++ b/flink-end-to-end-tests/flink-sql-client-test/pom.xml
@@ -63,33 +63,29 @@ under the License.
<dependency>
<!-- Used by maven-dependency-plugin -->
<groupId>org.apache.flink</groupId>
- <artifactId>flink-connector-kafka-0.9_${scala.binary.version}</artifactId>
+ <artifactId>flink-sql-connector-kafka-0.9_${scala.binary.version}</artifactId>
<version>${project.version}</version>
- <classifier>sql-jar</classifier>
<scope>provided</scope>
</dependency>
<dependency>
<!-- Used by maven-dependency-plugin -->
<groupId>org.apache.flink</groupId>
- <artifactId>flink-connector-kafka-0.10_${scala.binary.version}</artifactId>
+ <artifactId>flink-sql-connector-kafka-0.10_${scala.binary.version}</artifactId>
<version>${project.version}</version>
- <classifier>sql-jar</classifier>
<scope>provided</scope>
</dependency>
<dependency>
<!-- Used by maven-dependency-plugin -->
<groupId>org.apache.flink</groupId>
- <artifactId>flink-connector-kafka-0.11_${scala.binary.version}</artifactId>
+ <artifactId>flink-sql-connector-kafka-0.11_${scala.binary.version}</artifactId>
<version>${project.version}</version>
- <classifier>sql-jar</classifier>
<scope>provided</scope>
</dependency>
<dependency>
<!-- Used by maven-dependency-plugin -->
<groupId>org.apache.flink</groupId>
- <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
+ <artifactId>flink-sql-connector-kafka_${scala.binary.version}</artifactId>
<version>${project.version}</version>
- <classifier>sql-jar</classifier>
<scope>provided</scope>
</dependency>
<dependency>
@@ -173,23 +169,20 @@ under the License.
</artifactItem>-->
<artifactItem>
<groupId>org.apache.flink</groupId>
- <artifactId>flink-connector-kafka-0.10_${scala.binary.version}</artifactId>
+ <artifactId>flink-sql-connector-kafka-0.10_${scala.binary.version}</artifactId>
<version>${project.version}</version>
- <classifier>sql-jar</classifier>
<type>jar</type>
</artifactItem>
<artifactItem>
<groupId>org.apache.flink</groupId>
- <artifactId>flink-connector-kafka-0.11_${scala.binary.version}</artifactId>
+ <artifactId>flink-sql-connector-kafka-0.11_${scala.binary.version}</artifactId>
<version>${project.version}</version>
- <classifier>sql-jar</classifier>
<type>jar</type>
</artifactItem>
<artifactItem>
<groupId>org.apache.flink</groupId>
- <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
+ <artifactId>flink-sql-connector-kafka_${scala.binary.version}</artifactId>
<version>${project.version}</version>
- <classifier>sql-jar</classifier>
<type>jar</type>
</artifactItem>
<artifactItem>