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
The following commit(s) were added to refs/heads/master by this push:
new bc9b401ed1f [FLINK-28060][kafka] Bump Kafka to 3.2.1
bc9b401ed1f is described below
commit bc9b401ed1f2e7257c7b44c9838e34ede9c52ed5
Author: Chesnay Schepler <[email protected]>
AuthorDate: Wed Aug 10 12:13:55 2022 +0200
[FLINK-28060][kafka] Bump Kafka to 3.2.1
---
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 +-
flink-end-to-end-tests/test-scripts/test_sql_client.sh | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-formats/flink-avro-confluent-registry/pom.xml | 2 +-
9 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/flink-connectors/flink-connector-kafka/pom.xml
b/flink-connectors/flink-connector-kafka/pom.xml
index c95bbdc45e4..1336e3e6230 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.1.1</kafka.version>
+ <kafka.version>3.2.1</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 bfbf75b85db..e760f56bf50 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.1.1
+- org.apache.kafka:kafka-clients:3.2.1
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 efb7c72c86c..cf2c70e5fea 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.1.1</version>
+ <version>3.2.1</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.1.1</version>
+ <version>3.2.1</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 f1d95da8cc6..d912505f743 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.1.1", "universal", "kafka",
".*kafka.jar"}});
+ return Arrays.asList(new Object[][] {{"3.2.1", "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 6e47bf2e550..9cd32f14dcc 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.1.1"
+KAFKA_VERSION="3.2.1"
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 d532dd59024..dbdd457bd99 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.1.1"
+KAFKA_VERSION="3.2.1"
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_sql_client.sh
b/flink-end-to-end-tests/test-scripts/test_sql_client.sh
index 5a8980647af..ea6a343589b 100755
--- a/flink-end-to-end-tests/test-scripts/test_sql_client.sh
+++ b/flink-end-to-end-tests/test-scripts/test_sql_client.sh
@@ -19,7 +19,7 @@
set -Eeuo pipefail
-KAFKA_VERSION="3.1.1"
+KAFKA_VERSION="3.2.1"
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 e521d52ea75..103b0ebbff9 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.1.1
+- org.apache.kafka:kafka-clients:3.2.1
diff --git a/flink-formats/flink-avro-confluent-registry/pom.xml
b/flink-formats/flink-avro-confluent-registry/pom.xml
index 7d160a51f44..4b140068650 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.1.1</kafka.version>
+ <kafka.version>3.2.1</kafka.version>
<confluent.version>6.2.2</confluent.version>
</properties>
