Skip to content

Commit 9e29126

Browse files
authored
Fix for Antithesis regression test (#396)
Need to set the serdes for the new reduce operator
1 parent 9c032a1 commit 9e29126

File tree

1 file changed

+2
-1
lines changed
  • kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/regression/tests

1 file changed

+2
-1
lines changed

kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/regression/tests/STJoinExample.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
import org.apache.kafka.streams.kstream.Joined;
3232
import org.apache.kafka.streams.kstream.KStream;
3333
import org.apache.kafka.streams.kstream.KTable;
34+
import org.apache.kafka.streams.kstream.Materialized;
3435
import org.apache.kafka.streams.kstream.Produced;
3536
import org.apache.kafka.streams.kstream.TimeWindows;
3637

@@ -87,7 +88,7 @@ protected Topology buildTopology() {
8788
})
8889
.groupByKey()
8990
.windowedBy(TimeWindows.ofSizeAndGrace(Duration.ofDays(1), Duration.ofHours(12)))
90-
.reduce(EnrichedOrder::combineWith)
91+
.reduce(EnrichedOrder::combineWith, Materialized.with(Serdes.String(), RegressionSchema.enrichedOrderSerde()))
9192
.toStream()
9293
.selectKey((w, v) -> w.key())
9394
.to(

0 commit comments

Comments
 (0)