From 6a01e8956189b6cc84634be6a2fc90e2cd8bdaec Mon Sep 17 00:00:00 2001 From: "A. Sophie Blee-Goldman" Date: Thu, 21 Nov 2024 19:42:25 -0800 Subject: [PATCH] fix --- .../responsive/examples/regression/tests/STJoinExample.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/regression/tests/STJoinExample.java b/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/regression/tests/STJoinExample.java index 6fafe5532..088c4b261 100644 --- a/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/regression/tests/STJoinExample.java +++ b/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/regression/tests/STJoinExample.java @@ -31,6 +31,7 @@ import org.apache.kafka.streams.kstream.Joined; import org.apache.kafka.streams.kstream.KStream; import org.apache.kafka.streams.kstream.KTable; +import org.apache.kafka.streams.kstream.Materialized; import org.apache.kafka.streams.kstream.Produced; import org.apache.kafka.streams.kstream.TimeWindows; @@ -87,7 +88,7 @@ protected Topology buildTopology() { }) .groupByKey() .windowedBy(TimeWindows.ofSizeAndGrace(Duration.ofDays(1), Duration.ofHours(12))) - .reduce(EnrichedOrder::combineWith) + .reduce(EnrichedOrder::combineWith, Materialized.with(Serdes.String(), RegressionSchema.enrichedOrderSerde())) .toStream() .selectKey((w, v) -> w.key()) .to(