[FLINK-10891] Upgrade Kafka client version to 2.0.1

deepfield · Nov 16, 2018 · 0bf8ad8 · 0bf8ad8
1 parent acd041c
commit 0bf8ad8
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/flink-connectors/flink-connector-kafka/pom.xml b/flink-connectors/flink-connector-kafka/pom.xml
@@ -36,7 +36,7 @@ under the License.
  <packaging>jar</packaging>
 
  <properties>
- <kafka.version>2.0.0</kafka.version>
+ <kafka.version>2.0.1</kafka.version>
  </properties>
 
  <dependencies>

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
@@ -114,7 +114,7 @@ under the License.
  as we neither access nor package the kafka dependencies -->
  <groupId>org.apache.kafka</groupId>
  <artifactId>kafka-clients</artifactId>
- <version>2.0.0</version>
+ <version>2.0.1</version>
  </dependency>
  </dependencies>
  </dependencyManagement>

diff --git a/flink-end-to-end-tests/test-scripts/test_sql_client.sh b/flink-end-to-end-tests/test-scripts/test_sql_client.sh
@@ -20,7 +20,7 @@
 set -Eeuo pipefail
 
 KAFKA_CONNECTOR_VERSION="2.0"
-KAFKA_VERSION="2.0.0"
+KAFKA_VERSION="2.0.1"
 CONFLUENT_VERSION="5.0.0"
 CONFLUENT_MAJOR_VERSION="5.0"
 KAFKA_SQL_VERSION="universal"

diff --git a/flink-end-to-end-tests/test-scripts/test_sql_client_kafka.sh b/flink-end-to-end-tests/test-scripts/test_sql_client_kafka.sh
@@ -19,4 +19,4 @@
 
 set -Eeuo pipefail
 
-source "$(dirname "$0")"/test_sql_client_kafka_common.sh 2.0 2.0.0 5.0.0 5.0 "kafka" "universal"
+source "$(dirname "$0")"/test_sql_client_kafka_common.sh 2.0 2.0.1 5.0.0 5.0 "kafka" "universal"
diff --git a/flink-end-to-end-tests/test-scripts/test_streaming_kafka.sh b/flink-end-to-end-tests/test-scripts/test_streaming_kafka.sh
@@ -20,6 +20,6 @@
 set -Eeuo pipefail
 
 source "$(dirname "$0")"/common.sh
-source "$(dirname "$0")"/kafka-common.sh 2.0.0 5.0.0 5.0
+source "$(dirname "$0")"/kafka-common.sh 2.0.1 5.0.0 5.0
 
 source "$(dirname "$0")"/test_streaming_kafka_common.sh $FLINK_DIR/examples/streaming/KafkaExample.jar