X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Frecorder%2FRecorderApplicationIT.java;h=9d73e7ef0ef78d4c2e992965060713971b8d3f16;hb=2893aaa541057a9ab6a253b1995307c1f9fe0ed8;hp=5f5893ecf0372f5dd75b222ff35887a10ba18e9a;hpb=20648dca11997490c9e464afc07ccf15b9ef3e61;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java b/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java
index 5f5893e..9d73e7e 100644
--- a/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java
@@ -22,7 +22,6 @@ import org.springframework.util.MultiValueMap;
 
 import java.time.Duration;
 import java.util.List;
-import java.util.stream.Stream;
 
 import static de.juplo.kafka.wordcount.recorder.RecorderApplicationIT.TOPIC_OUT;
 import static org.assertj.core.api.Assertions.assertThat;
@@ -63,8 +62,8 @@ class RecorderApplicationIT
 	{
 		MultiValueMap<String, TestRecording> recordings = new LinkedMultiValueMap<>();
 
-		Stream
-				.of(TestData.INPUT_MESSAGES)
+		TestData
+				.getInputMessages()
 				.forEach(kv ->
 				{
 					sendRedording(kv.key, kv.value);