From 43c1ffbf29f53e9a2a560f3fcd666f420d21dc4e Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 6 Jul 2024 09:21:45 +0200
Subject: [PATCH] Switched from an inner to a left join

---
 pom.xml                                                     | 4 ++--
 .../join/stream/stream/StreamStreamLeftJoinTest.java        | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/pom.xml b/pom.xml
index 6063371..4e264b6 100644
--- a/pom.xml
+++ b/pom.xml
@@ -12,10 +12,10 @@
 	</parent>
 
 	<groupId>de.juplo.kafka.streams.demos</groupId>
-	<artifactId>stream-stream--inner-join</artifactId>
+	<artifactId>stream-stream--left-join</artifactId>
 	<version>1.0.0-SNAPSHOT</version>
 
-	<name>Outcome of an Inner Stream/Stream-Join</name>
+	<name>Outcome of a Left Stream/Stream-Join</name>
 
 	<properties>
 		<java.version>21</java.version>
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 09410b4..93cc03d 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
@@ -33,7 +33,7 @@ public class StreamStreamLeftJoinTest
     KStream<String, String> right = builder.stream(RIGHT);
 
     left
-        .join(
+        .leftJoin(
             right,
             (valueLeft, valueRight) -> valueLeft + "-" + valueRight,
             WINDOWS)
@@ -90,10 +90,10 @@ public class StreamStreamLeftJoinTest
     assertThatOutcomeIs();
 
     sendLeftAt("F", 120);
-    assertThatOutcomeIs();
+    assertThatOutcomeIs("E-null");
 
     sendRightAt("f", 140);
-    assertThatOutcomeIs();
+    assertThatOutcomeIs("F-null");
 
     sendLeftAt("G", 160);
     assertThatOutcomeIs();
-- 
2.20.1