From 251b47c0c23711d25b5955f4c6c797e5d623ca87 Mon Sep 17 00:00:00 2001
From: Philipp Schirmer <philipp.schirmer@bakdata.com>
Date: Fri, 16 Aug 2024 13:26:01 +0200
Subject: [PATCH 1/2] Upgrade to Kafka 3.7

---
 gradle.properties | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/gradle.properties b/gradle.properties
index a3b6ee4..7cfb76f 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -3,7 +3,7 @@ org.gradle.caching=true
 org.gradle.parallel=true
 junit5Version=5.10.2
 junit4Version=4.13.2
-confluentVersion=7.6.0
-kafkaVersion=3.6.1
-log4jVersion=2.23.0
+confluentVersion=7.7.0
+kafkaVersion=3.7.1
+log4jVersion=2.23.1
 org.gradle.jvmargs=-Xmx2048m

From 2eaeb566606932a442a4baa3d880cc1a9b129ec6 Mon Sep 17 00:00:00 2001
From: Philipp Schirmer <philipp.schirmer@bakdata.com>
Date: Fri, 16 Aug 2024 13:36:22 +0200
Subject: [PATCH 2/2] Upgrade to Kafka 3.7

---
 .../bakdata/fluent_kafka_streams_tests/TestTopology.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java b/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java
index 2af58f2..d1ff091 100644
--- a/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java
+++ b/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java
@@ -322,14 +322,16 @@ protected <K, V> TestTopology<K, V> with(
      * Get the default serde of the key type in your application.
      */
     private Serde<DefaultK> getDefaultKeySerde() {
-        return this.defaultKeySerde != null ? this.defaultKeySerde : this.getStreamsConfig().defaultKeySerde();
+        return this.defaultKeySerde != null ? this.defaultKeySerde
+                : (Serde<DefaultK>) this.getStreamsConfig().defaultKeySerde();
     }
 
     /**
      * Get the default serde of the value type in your application.
      */
     private Serde<DefaultV> getDefaultValueSerde() {
-        return this.defaultValueSerde != null ? this.defaultValueSerde : this.getStreamsConfig().defaultValueSerde();
+        return this.defaultValueSerde != null ? this.defaultValueSerde
+                : (Serde<DefaultV>) this.getStreamsConfig().defaultValueSerde();
     }
 
     /**