Skip to content

Commit bdeb667

Browse files
authored
Upgrade to Kafka 3.7 (#96)
1 parent ed36762 commit bdeb667

File tree

2 files changed

+7
-5
lines changed

2 files changed

+7
-5
lines changed

fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java

+4-2
Original file line numberDiff line numberDiff line change
@@ -322,14 +322,16 @@ protected <K, V> TestTopology<K, V> with(
322322
* Get the default serde of the key type in your application.
323323
*/
324324
private Serde<DefaultK> getDefaultKeySerde() {
325-
return this.defaultKeySerde != null ? this.defaultKeySerde : this.getStreamsConfig().defaultKeySerde();
325+
return this.defaultKeySerde != null ? this.defaultKeySerde
326+
: (Serde<DefaultK>) this.getStreamsConfig().defaultKeySerde();
326327
}
327328

328329
/**
329330
* Get the default serde of the value type in your application.
330331
*/
331332
private Serde<DefaultV> getDefaultValueSerde() {
332-
return this.defaultValueSerde != null ? this.defaultValueSerde : this.getStreamsConfig().defaultValueSerde();
333+
return this.defaultValueSerde != null ? this.defaultValueSerde
334+
: (Serde<DefaultV>) this.getStreamsConfig().defaultValueSerde();
333335
}
334336

335337
/**

gradle.properties

+3-3
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ org.gradle.caching=true
33
org.gradle.parallel=true
44
junit5Version=5.10.2
55
junit4Version=4.13.2
6-
confluentVersion=7.6.0
7-
kafkaVersion=3.6.1
8-
log4jVersion=2.23.0
6+
confluentVersion=7.7.0
7+
kafkaVersion=3.7.1
8+
log4jVersion=2.23.1
99
org.gradle.jvmargs=-Xmx2048m

0 commit comments

Comments
 (0)