Upgrade to Kafka 3.7

bakdata · Aug 16, 2024 · 2eaeb56 · 2eaeb56
1 parent 251b47c
commit 2eaeb56
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...afka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java b/...afka-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();
     }
 
     /**