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 (file)
--- 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();
   }