This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.16 by this push:
new 90fba507a82 [FLINK-29513][Connector/Kafka] Update Kafka to version
3.2.3 which contains certain security fixes
90fba507a82 is described below
commit 90fba507a824eab2075aa42b0a82cc0b69dc44de
Author: Martijn Visser <[email protected]>
AuthorDate: Wed Oct 5 21:58:42 2022 -0500
[FLINK-29513][Connector/Kafka] Update Kafka to version 3.2.3 which contains
certain security fixes
---
flink-connectors/flink-connector-kafka/pom.xml | 2 +-
.../flink-sql-connector-kafka/src/main/resources/META-INF/NOTICE | 2 +-
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml | 4 ++--
.../java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java | 2 +-
flink-end-to-end-tests/test-scripts/test_confluent_schema_registry.sh | 2 +-
flink-end-to-end-tests/test-scripts/test_pyflink.sh | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-formats/flink-avro-confluent-registry/pom.xml | 2 +-
8 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/flink-connectors/flink-connector-kafka/pom.xml
b/flink-connectors/flink-connector-kafka/pom.xml
index 1336e3e6230..604b6c9237d 100644
--- 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
index 14c0b5a8b51..533611f3d5a 100644
---
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://www.apache.org/).
This project bundles the following dependencies under the Apache Software
License 2.0. (http://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
index d07c35ac15e..1152140d91b 100644
--- 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/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
index 9827ac69a41..e8a563eee98 100644
---
a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
+++
b/flink-end-to-end-tests/flink-end-to-end-tests-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/test-scripts/test_confluent_schema_registry.sh
b/flink-end-to-end-tests/test-scripts/test_confluent_schema_registry.sh
index 9cd32f14dcc..03d6e209d8e 100755
--- 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
index dbdd457bd99..83284350da3 100755
--- 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/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/src/main/resources/META-INF/NOTICE
b/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/src/main/resources/META-INF/NOTICE
index 664a016499a..9c512c9b04f 100644
---
a/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/src/main/resources/META-INF/NOTICE
+++
b/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/src/main/resources/META-INF/NOTICE
@@ -6,4 +6,4 @@ The Apache Software Foundation (http://www.apache.org/).
This project bundles the following dependencies under the Apache Software
License 2.0. (http://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
index 4b140068650..625c004a0aa 100644
--- 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>
