--- /dev/null
+package de.juplo.kafka.wordcount.recorder;
+
+import org.apache.kafka.streams.KeyValue;
+
+
+class TestData
+{
+ static final String PETER = "päter";
+ static final String KLAUS = "klühs";
+
+ static final KeyValue<String, String>[] INPUT_MESSAGES = new KeyValue[]
+ {
+ new KeyValue<>("päter", "Hall° Wält?¢*&%€!"),
+ new KeyValue<>("päter", "Hallo Welt!"),
+ new KeyValue<>("klühs", "Müsch gäb's auch!"),
+ new KeyValue<>("päter", "Boäh, echt! ß mal nä Nümmäh!"),
+ };
+}