From 388a96f350070b33a4a875bff547a0101457d427 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 6 Jul 2024 00:25:17 +0200
Subject: [PATCH] Forced emidiate emitt of join-results

---
 .../streams/join/stream/stream/StreamStreamLeftJoinTest.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/test/java/de/juplo/kafka/streams/join/stream/stream/StreamStreamLeftJoinTest.java b/src/test/java/de/juplo/kafka/streams/join/stream/stream/StreamStreamLeftJoinTest.java
index 93cc03d..0e3b5d0 100644
--- a/src/test/java/de/juplo/kafka/streams/join/stream/stream/StreamStreamLeftJoinTest.java
+++ b/src/test/java/de/juplo/kafka/streams/join/stream/stream/StreamStreamLeftJoinTest.java
@@ -45,6 +45,7 @@ public class StreamStreamLeftJoinTest
     Properties properties = new Properties();
     properties.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.StringSerde.class);
     properties.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.StringSerde.class);
+    properties.put(StreamsConfig.InternalConfig.EMIT_INTERVAL_MS_KSTREAMS_OUTER_JOIN_SPURIOUS_RESULTS_FIX, 0l);
 
     TopologyTestDriver testDriver = new TopologyTestDriver(topology, properties);
 
-- 
2.20.1