From 1fe3f9c6ce98e70c3d126ed03633ff6247d5e03b Mon Sep 17 00:00:00 2001 From: Philipp Schirmer Date: Fri, 5 Jun 2026 12:28:49 +0200 Subject: [PATCH] Upgrade to Kafka 4.3 --- gradle/libs.versions.toml | 2 +- .../java/com/bakdata/kafka/producer/ConfiguredProducerApp.java | 2 +- .../java/com/bakdata/kafka/streams/ConfiguredStreamsApp.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml index aaaf2ee1e..aa1b8a2e0 100644 --- a/gradle/libs.versions.toml +++ b/gradle/libs.versions.toml @@ -2,7 +2,7 @@ junit = "6.0.3" mockito = "5.23.0" testcontainers = "2.0.5" -kafkaUtils = "1.5.0" +kafkaUtils = "1.5.1-SNAPSHOT" [libraries] kafka-bom = { group = "com.bakdata.kafka", name = "kafka-bom", version.ref = "kafkaUtils" } diff --git a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/producer/ConfiguredProducerApp.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/producer/ConfiguredProducerApp.java index 4d5498df3..0f9cd361b 100644 --- a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/producer/ConfiguredProducerApp.java +++ b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/producer/ConfiguredProducerApp.java @@ -36,7 +36,7 @@ import lombok.NonNull; import lombok.RequiredArgsConstructor; import org.apache.kafka.clients.producer.ProducerConfig; -import org.apache.kafka.common.record.CompressionType; +import org.apache.kafka.common.record.internal.CompressionType; /** * A {@link ProducerApp} with a corresponding {@link ProducerAppConfiguration} diff --git a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/streams/ConfiguredStreamsApp.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/streams/ConfiguredStreamsApp.java index 5fb01ddb2..95159111b 100644 --- a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/streams/ConfiguredStreamsApp.java +++ b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/streams/ConfiguredStreamsApp.java @@ -36,7 +36,7 @@ import lombok.NonNull; import lombok.RequiredArgsConstructor; import org.apache.kafka.clients.producer.ProducerConfig; -import org.apache.kafka.common.record.CompressionType; +import org.apache.kafka.common.record.internal.CompressionType; import org.apache.kafka.streams.StreamsConfig; import org.apache.kafka.streams.Topology;