[FLINK-29513][Connector/Kafka] Update Kafka to version 3.2.3 which co…

…ntains certain security fixes
mbalassi · Oct 6, 2022 · a223063 · a223063
1 parent 49e0041
commit a223063
Show file tree

Hide file tree

Showing 9 changed files with 10 additions and 10 deletions.
diff --git a/flink-connectors/flink-connector-kafka/pom.xml b/flink-connectors/flink-connector-kafka/pom.xml
@@ -35,7 +35,7 @@ under the License.
  <packaging>jar</packaging>
 
  <properties>
- <kafka.version>3.2.1</kafka.version>
+ <kafka.version>3.2.3</kafka.version>
  </properties>
 
  <dependencies>

diff --git a/flink-connectors/flink-sql-connector-kafka/src/main/resources/META-INF/NOTICE b/flink-connectors/flink-sql-connector-kafka/src/main/resources/META-INF/NOTICE
@@ -6,4 +6,4 @@ The Apache Software Foundation (http:https://www.apache.org/).
 
 This project bundles the following dependencies under the Apache Software License 2.0. (http:https://www.apache.org/licenses/LICENSE-2.0.txt)
 
-- org.apache.kafka:kafka-clients:3.2.1
+- org.apache.kafka:kafka-clients:3.2.3
diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml
@@ -76,7 +76,7 @@ under the License.
  <dependency>
  <groupId>org.apache.kafka</groupId>
  <artifactId>kafka-clients</artifactId>
- <version>3.2.1</version>
+ <version>3.2.3</version>
  </dependency>
 
  <!-- The following dependencies are for connector/format sql-jars that
@@ -234,7 +234,7 @@ under the License.
  <artifactItem>
  <groupId>org.apache.kafka</groupId>
  <artifactId>kafka-clients</artifactId>
- <version>3.2.1</version>
+ <version>3.2.3</version>
  <destFileName>kafka-clients.jar</destFileName>
  <type>jar</type>
  <outputDirectory>${project.build.directory}/dependencies</outputDirectory>

diff --git a/...ts-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java b/...ts-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
@@ -72,7 +72,7 @@ public class SQLClientKafkaITCase extends TestLogger {
 
  @Parameterized.Parameters(name = "{index}: kafka-version:{0} kafka-sql-version:{1}")
  public static Collection<Object[]> data() {
- return Arrays.asList(new Object[][] {{"3.2.1", "universal", "kafka", ".*kafka.jar"}});
+ return Arrays.asList(new Object[][] {{"3.2.3", "universal", "kafka", ".*kafka.jar"}});
  }
 
  private static Configuration getConfiguration() {

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
@@ -61,7 +61,7 @@ under the License.
  <dependency>
  <groupId>org.apache.kafka</groupId>
  <artifactId>kafka-clients</artifactId>
- <version>3.2.1</version>
+ <version>3.2.3</version>
  <scope>test</scope>
  </dependency>
  <dependency>

diff --git a/flink-end-to-end-tests/test-scripts/test_confluent_schema_registry.sh b/flink-end-to-end-tests/test-scripts/test_confluent_schema_registry.sh
@@ -19,7 +19,7 @@
 
 set -Eeuo pipefail
 
-KAFKA_VERSION="3.2.1"
+KAFKA_VERSION="3.2.3"
 CONFLUENT_VERSION="6.2.2"
 CONFLUENT_MAJOR_VERSION="6.2"
 # Check the Confluent Platform <> Apache Kafka compatibility matrix when updating KAFKA_VERSION

diff --git a/flink-end-to-end-tests/test-scripts/test_pyflink.sh b/flink-end-to-end-tests/test-scripts/test_pyflink.sh
@@ -19,7 +19,7 @@
 
 set -Eeuo pipefail
 
-KAFKA_VERSION="3.2.1"
+KAFKA_VERSION="3.2.3"
 CONFLUENT_VERSION="6.2.2"
 CONFLUENT_MAJOR_VERSION="6.2"
 # Check the Confluent Platform <> Apache Kafka compatibility matrix when updating KAFKA_VERSION

diff --git a/...es-build-helper/flink-examples-streaming-state-machine/src/main/resources/META-INF/NOTICE b/...es-build-helper/flink-examples-streaming-state-machine/src/main/resources/META-INF/NOTICE
@@ -6,4 +6,4 @@ The Apache Software Foundation (http:https://www.apache.org/).
 
 This project bundles the following dependencies under the Apache Software License 2.0. (http:https://www.apache.org/licenses/LICENSE-2.0.txt)
 
-- org.apache.kafka:kafka-clients:3.2.1
+- org.apache.kafka:kafka-clients:3.2.3
diff --git a/flink-formats/flink-avro-confluent-registry/pom.xml b/flink-formats/flink-avro-confluent-registry/pom.xml
@@ -32,7 +32,7 @@ under the License.
  <name>Flink : Formats : Avro confluent registry</name>
 
  <properties>
- <kafka.version>3.2.1</kafka.version>
+ <kafka.version>3.2.3</kafka.version>
  <confluent.version>6.2.2</confluent.version>
  </properties>