counter: 1.2.15 - `TestData` only holds and asserts the test-data

[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / counter / CounterApplicationIT.java

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java b/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
index 3889cea..ad4faf2 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
@@ -20,6 +20,7 @@ import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 
 import java.time.Duration;
+import java.util.stream.Stream;
 
 import static de.juplo.kafka.wordcount.counter.CounterApplicationIT.TOPIC_IN;
 import static de.juplo.kafka.wordcount.counter.CounterApplicationIT.TOPIC_OUT;
@@ -66,7 +67,9 @@ public class CounterApplicationIT
        @Test
        void testSendMessage()
        {
-               TestData.injectInputMessages((key, value) -> kafkaTemplate.send(TOPIC_IN, key, value));
+               Stream
+                               .of(TestData.INPUT_MESSAGES)
+                               .forEach(word -> kafkaTemplate.send(TOPIC_IN, word.getUser(), word));
 
                await("Expected messages")
                                .atMost(Duration.ofSeconds(10))