This is an automated email from the ASF dual-hosted git repository.
FrankChen021 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new 5f0d65d06ba Upgrade Kafka to 4.3.0 (#19584)
5f0d65d06ba is described below
commit 5f0d65d06ba9501e3dd1c42250e55c73e30e115f
Author: Shekhar Prasad Rajak <[email protected]>
AuthorDate: Tue Jul 14 07:29:52 2026 +0530
Upgrade Kafka to 4.3.0 (#19584)
---
.../query/lookup/TestKafkaExtractionCluster.java | 2 +-
.../indexing/kafka/simulate/KafkaResource.java | 2 +-
.../indexing/kafka/test/EmbeddedKafkaBroker.java | 2 +-
licenses.yaml | 28 ++++++++--------------
pom.xml | 2 +-
5 files changed, 14 insertions(+), 22 deletions(-)
diff --git
a/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/TestKafkaExtractionCluster.java
b/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/TestKafkaExtractionCluster.java
index 417166f7b31..2e20553d533 100644
---
a/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/TestKafkaExtractionCluster.java
+++
b/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/TestKafkaExtractionCluster.java
@@ -73,7 +73,7 @@ public class TestKafkaExtractionCluster
private final Closer closer = Closer.create();
private static final String KAFKA_IMAGE =
- System.getProperty("druid.testing.kafka.image", "apache/kafka:4.2.0");
+ System.getProperty("druid.testing.kafka.image", "apache/kafka:4.3.0");
private KafkaContainer kafkaServer;
private Injector injector;
diff --git
a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/simulate/KafkaResource.java
b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/simulate/KafkaResource.java
index 0c7851b197b..8ef0c888b7e 100644
---
a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/simulate/KafkaResource.java
+++
b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/simulate/KafkaResource.java
@@ -57,7 +57,7 @@ public class KafkaResource extends
StreamIngestResource<KafkaContainer>
* defaults to {@code apache/kafka}. Environments that cannot run that
* image should set the system property to {@code apache/kafka-native}.
*/
- private static final String KAFKA_IMAGE =
System.getProperty("druid.testing.kafka.image", "apache/kafka:4.2.0");
+ private static final String KAFKA_IMAGE =
System.getProperty("druid.testing.kafka.image", "apache/kafka:4.3.0");
private EmbeddedDruidCluster cluster;
diff --git
a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/test/EmbeddedKafkaBroker.java
b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/test/EmbeddedKafkaBroker.java
index c223337decb..4bd3328d276 100644
---
a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/test/EmbeddedKafkaBroker.java
+++
b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/test/EmbeddedKafkaBroker.java
@@ -36,7 +36,7 @@ import java.util.concurrent.ThreadLocalRandom;
public class EmbeddedKafkaBroker implements Closeable
{
private static final String KAFKA_IMAGE =
- System.getProperty("druid.testing.kafka.image", "apache/kafka:4.2.0");
+ System.getProperty("druid.testing.kafka.image", "apache/kafka:4.3.0");
private final KafkaContainer container;
diff --git a/licenses.yaml b/licenses.yaml
index d36338a1fd3..64a7f9ef20d 100644
--- a/licenses.yaml
+++ b/licenses.yaml
@@ -3458,7 +3458,7 @@ libraries:
---
name: Apache Kafka
-version: 4.2.0
+version: 4.3.0
license_category: binary
module: extensions/druid-kafka-indexing-service
license_name: Apache License version 2.0
@@ -3467,7 +3467,7 @@ libraries:
notices:
- kafka-clients: |
Apache Kafka
- Copyright 2024 The Apache Software Foundation.
+ Copyright 2026 The Apache Software Foundation.
This product includes software developed at
The Apache Software Foundation (https://www.apache.org/).
@@ -3480,15 +3480,11 @@ notices:
https://github.com/jlink/jqwik.
The streams-scala (streams/streams-scala) module was donated by
Lightbend and the original code was copyrighted by them:
- Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
- Copyright (C) 2017-2018 Alexis Seigneurin.
-
- This project contains the following code copied from Apache Hadoop:
- clients/src/main/java/org/apache/kafka/common/utils/PureJavaCrc32C.java
- Some portions of this file Copyright (c) 2004-2006 Intel Corporation
and licensed under the BSD license.
+ Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ Copyright (C) 2017-2018 Alexis Seigneurin.
This project contains the following code copied from Apache Hive:
-
streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java
+
streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java
---
@@ -4462,13 +4458,13 @@ name: Apache Kafka
license_category: binary
module: extensions/kafka-extraction-namespace
license_name: Apache License version 2.0
-version: 4.2.0
+version: 4.3.0
libraries:
- org.apache.kafka: kafka-clients
notices:
- kafka-clients: |
Apache Kafka
- Copyright 2023 The Apache Software Foundation.
+ Copyright 2026 The Apache Software Foundation.
This product includes software developed at
The Apache Software Foundation (https://www.apache.org/).
@@ -4481,15 +4477,11 @@ notices:
https://github.com/jlink/jqwik.
The streams-scala (streams/streams-scala) module was donated by
Lightbend and the original code was copyrighted by them:
- Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
- Copyright (C) 2017-2018 Alexis Seigneurin.
-
- This project contains the following code copied from Apache Hadoop:
- clients/src/main/java/org/apache/kafka/common/utils/PureJavaCrc32C.java
- Some portions of this file Copyright (c) 2004-2006 Intel Corporation
and licensed under the BSD license.
+ Copyright (C) 2018 Lightbend Inc. <https://www.lightbend.com>
+ Copyright (C) 2017-2018 Alexis Seigneurin.
This project contains the following code copied from Apache Hive:
-
streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java
+
streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java
---
diff --git a/pom.xml b/pom.xml
index b8c72b78a03..0f5e45dc7d1 100644
--- a/pom.xml
+++ b/pom.xml
@@ -75,7 +75,7 @@
<project.build.resourceEncoding>UTF-8</project.build.resourceEncoding>
<aether.version>0.9.0.M2</aether.version>
<apache.curator.version>5.8.0</apache.curator.version>
- <apache.kafka.version>4.2.0</apache.kafka.version>
+ <apache.kafka.version>4.3.0</apache.kafka.version>
<!-- when updating apache ranger, verify the usage of aws-bundle-sdk
vs aws-logs-sdk
and update as needed in
extensions-contrib/druid-ranger-security/pom.xml -->
<apache.ranger.version>2.8.0</apache.ranger.version>
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
