From e21271b857364e570a8dfbf272b34f0f6d0f9128 Mon Sep 17 00:00:00 2001 From: "S.Y. Wang" Date: Wed, 25 Feb 2026 11:45:18 +0800 Subject: [PATCH 1/2] Bump kafka dependency to 3.9.1 --- build.gradle | 2 +- testing/build.gradle | 1 + .../com/linecorp/decaton/testing/EmbeddedKafkaCluster.java | 3 ++- .../linecorp/decaton/testing/processor/ProducerAdaptor.java | 6 ++++++ 4 files changed, 10 insertions(+), 2 deletions(-) diff --git a/build.gradle b/build.gradle index aa9e464f..49b1ca9c 100644 --- a/build.gradle +++ b/build.gradle @@ -67,7 +67,7 @@ subprojects { // Freezing this to 1.X until https://github.com/spring-projects/spring-boot/issues/12649 is resolved slf4jVersion = "1.7.36" protobufVersion = "3.22.3" - kafkaVersion = "3.2.3" + kafkaVersion = "3.9.1" micrometerVersion = "1.12.4" micrometerTracingVersion = "1.2.4" lombokVersion = "1.18.30" diff --git a/testing/build.gradle b/testing/build.gradle index ccae003b..0597aabb 100644 --- a/testing/build.gradle +++ b/testing/build.gradle @@ -25,6 +25,7 @@ dependencies { implementation "org.apache.kafka:kafka-clients:$kafkaVersion" implementation "org.apache.kafka:kafka_2.12:$kafkaVersion" + implementation "org.apache.kafka:kafka-server:$kafkaVersion" implementation "org.apache.kafka:kafka-clients:$kafkaVersion:test" implementation "org.apache.kafka:kafka_2.12:$kafkaVersion:test" diff --git a/testing/src/main/java/com/linecorp/decaton/testing/EmbeddedKafkaCluster.java b/testing/src/main/java/com/linecorp/decaton/testing/EmbeddedKafkaCluster.java index 98acb156..1a63abfe 100644 --- a/testing/src/main/java/com/linecorp/decaton/testing/EmbeddedKafkaCluster.java +++ b/testing/src/main/java/com/linecorp/decaton/testing/EmbeddedKafkaCluster.java @@ -89,7 +89,8 @@ private static Properties createBrokerConfig(int brokerId, String zkConnect) { 1, // logDir count false, // disable delegation token 1, // num partitions - (short) 1 // default replication factor + (short) 1, // default replication factor + false // disable fetch from follower ); } diff --git a/testing/src/main/java/com/linecorp/decaton/testing/processor/ProducerAdaptor.java b/testing/src/main/java/com/linecorp/decaton/testing/processor/ProducerAdaptor.java index 2298e09b..52e078c9 100644 --- a/testing/src/main/java/com/linecorp/decaton/testing/processor/ProducerAdaptor.java +++ b/testing/src/main/java/com/linecorp/decaton/testing/processor/ProducerAdaptor.java @@ -31,6 +31,7 @@ import org.apache.kafka.common.MetricName; import org.apache.kafka.common.PartitionInfo; import org.apache.kafka.common.TopicPartition; +import org.apache.kafka.common.Uuid; import org.apache.kafka.common.errors.ProducerFencedException; public abstract class ProducerAdaptor implements Producer { @@ -97,6 +98,11 @@ public List partitionsFor(String topic) { return delegate.metrics(); } + @Override + public Uuid clientInstanceId(Duration timeout) { + return delegate.clientInstanceId(timeout); + } + @Override public void close() { delegate.close(); From dbbc57e60a3ea5d6ac1fc02f3c3644fb39f6f7eb Mon Sep 17 00:00:00 2001 From: "S.Y. Wang" Date: Thu, 26 Feb 2026 15:46:05 +0800 Subject: [PATCH 2/2] Bump to 3.9.2 --- build.gradle | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/build.gradle b/build.gradle index 49b1ca9c..e2f1f5f1 100644 --- a/build.gradle +++ b/build.gradle @@ -67,7 +67,7 @@ subprojects { // Freezing this to 1.X until https://github.com/spring-projects/spring-boot/issues/12649 is resolved slf4jVersion = "1.7.36" protobufVersion = "3.22.3" - kafkaVersion = "3.9.1" + kafkaVersion = "3.9.2" micrometerVersion = "1.12.4" micrometerTracingVersion = "1.2.4" lombokVersion = "1.18.30"