X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Ftop10%2FTop10StreamProcessorTopologyTest.java;h=90d8e4cb90987d0455c84f67252b6080e5d9bed1;hb=478b25d6700bd0a48b55647f09386f3b1d59fa29;hp=cd09c066ea852b6d6b1503147c535441f716ed63;hpb=6738dd374575d4d86a966972d2e25661c2ad1523;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessorTopologyTest.java b/src/test/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessorTopologyTest.java
index cd09c06..90d8e4c 100644
--- a/src/test/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessorTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessorTopologyTest.java
@@ -20,7 +20,6 @@ import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 
 import java.util.Map;
-import java.util.stream.Stream;
 
 import static de.juplo.kafka.wordcount.top10.Top10ApplicationConfiguration.serializationConfig;
 
@@ -68,8 +67,8 @@ public class Top10StreamProcessorTopologyTest
   @Test
   public void test()
   {
-    Stream
-        .of(TestData.INPUT_MESSAGES)
+    TestData
+        .getInputMessages()
         .forEach(kv -> in.pipeInput(kv.key, kv.value));
 
     MultiValueMap<TestUser, TestRanking> receivedMessages = new LinkedMultiValueMap<>();