X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Frecorder%2FRecorderApplicationIT.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Frecorder%2FRecorderApplicationIT.java;h=5f5893ecf0372f5dd75b222ff35887a10ba18e9a;hb=20648dca11997490c9e464afc07ccf15b9ef3e61;hp=aaed33ed0f0aeb8ee1ebfd7c179a7d830bcacd28;hpb=95229c5ee1ecc26082626dfa3206250f4280f888;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 aaed33e..5f5893e 100644
--- a/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java
@@ -64,15 +64,11 @@ class RecorderApplicationIT
 		MultiValueMap<String, TestRecording> recordings = new LinkedMultiValueMap<>();
 
 		Stream
-				.of(
-						new TestRecording("päter", "Hall° Wält?¢*&%€!"),
-						new TestRecording("päter", "Hallo Welt!"),
-						new TestRecording("klühs", "Müsch gäb's auch!"),
-						new TestRecording("päter", "Boäh, echt! ß mal nä Nümmäh!"))
-				.forEach(recording ->
+				.of(TestData.INPUT_MESSAGES)
+				.forEach(kv ->
 				{
-					sendRedording(recording.getUser(), recording.getSentence());
-					recordings.add(recording.getUser(), recording);
+					sendRedording(kv.key, kv.value);
+					recordings.add(kv.key, TestRecording.of(kv.key, kv.value));
 				});