This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5192ad5a8ac52ed0a8e94e9cfd8b93a740b38719 Author: Aljoscha Krettek <[email protected]> AuthorDate: Mon Oct 8 17:31:01 2018 +0200 [FLINK-7811] Update Kafka version of Kafka connector base --- flink-connectors/flink-connector-kafka-0.8/pom.xml | 8 ++++++++ flink-connectors/flink-connector-kafka-base/pom.xml | 13 ++++++++++--- 2 files changed, 18 insertions(+), 3 deletions(-) diff --git a/flink-connectors/flink-connector-kafka-0.8/pom.xml b/flink-connectors/flink-connector-kafka-0.8/pom.xml index df1afb5..52f0ef1 100644 --- a/flink-connectors/flink-connector-kafka-0.8/pom.xml +++ b/flink-connectors/flink-connector-kafka-0.8/pom.xml @@ -62,6 +62,14 @@ under the License. <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kafka-base_${scala.binary.version}</artifactId> <version>${project.version}</version> + <exclusions> + <!-- we need to exclude because the base module has this but it doesn't exist + for Kafka 0.8--> + <exclusion> + <groupId>org.apache.kafka</groupId> + <artifactId>kafka-clients</artifactId> + </exclusion> + </exclusions> </dependency> <dependency> diff --git a/flink-connectors/flink-connector-kafka-base/pom.xml b/flink-connectors/flink-connector-kafka-base/pom.xml index df98dd9..a0feec9 100644 --- a/flink-connectors/flink-connector-kafka-base/pom.xml +++ b/flink-connectors/flink-connector-kafka-base/pom.xml @@ -37,7 +37,7 @@ under the License. <!-- Allow users to pass custom connector versions --> <properties> - <kafka.version>0.8.2.2</kafka.version> + <kafka.version>0.10.2.1</kafka.version> </properties> <dependencies> @@ -84,8 +84,17 @@ under the License. <dependency> <groupId>org.apache.kafka</groupId> + <artifactId>kafka-clients</artifactId> + <version>${kafka.version}</version> + </dependency> + + <!-- test dependencies --> + + <dependency> + <groupId>org.apache.kafka</groupId> <artifactId>kafka_${scala.binary.version}</artifactId> <version>${kafka.version}</version> + <scope>test</scope> <exclusions> <exclusion> <groupId>com.sun.jmx</groupId> @@ -126,8 +135,6 @@ under the License. </exclusions> </dependency> - <!-- test dependencies --> - <!-- force using the latest zkclient --> <dependency> <groupId>com.101tec</groupId>
