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 TestTopology with( * Get the default serde of the key type in your application. */ private Serde getDefaultKeySerde() { - return this.defaultKeySerde != null ? this.defaultKeySerde : this.getStreamsConfig().defaultKeySerde(); + return this.defaultKeySerde != null ? this.defaultKeySerde + : (Serde) this.getStreamsConfig().defaultKeySerde(); } /** * Get the default serde of the value type in your application. */ private Serde getDefaultValueSerde() { - return this.defaultValueSerde != null ? this.defaultValueSerde : this.getStreamsConfig().defaultValueSerde(); + return this.defaultValueSerde != null ? this.defaultValueSerde + : (Serde) this.getStreamsConfig().defaultValueSerde(); } /** 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