X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterApplicationIT.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterApplicationIT.java;h=ad4faf2a120d90dd2b59c0d8a469376eab361ce2;hb=48dabf093db63d517252f47b15f597e80852e9d4;hp=3889ceaf94bc7b51f87a9d1e4349982c14fc9542;hpb=7768a8989ee4c1a9340f2e2e396aa7335b37fb0a;p=demos%2Fkafka%2Fwordcount

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
--- 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))