From: Kai Moritz <kai@juplo.de>
Date: Fri, 5 Jul 2024 21:54:30 +0000 (+0200)
Subject: Added forgotten input record from original example
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=2fe0c2b692eb6e96c528b0febf38687889085110;p=demos%2Fkafka%2Fwordcount

Added forgotten input record from original example
---

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java b/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
index 4dedf0f..3812e86 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
@@ -91,6 +91,9 @@ public class StreamStreamJoinTopologyTest
     inLeft.pipeInput(recordOf("F", 60));
     assertThatOutcomeIs();
 
+    inRight.pipeInput(recordOf("f", 80));
+    assertThatOutcomeIs();
+
     inLeft.pipeInput(recordOf("G", 100));
     assertThatOutcomeIs();
   }