1 package de.juplo.kafka.wordcount.recorder;
3 import org.apache.kafka.streams.KeyValue;
8 static final String PETER = "päter";
9 static final String KLAUS = "klühs";
11 static final KeyValue<String, String>[] INPUT_MESSAGES = new KeyValue[]
13 new KeyValue<>("päter", "Hall° Wält?¢*&%€!"),
14 new KeyValue<>("päter", "Hallo Welt!"),
15 new KeyValue<>("klühs", "Müsch gäb's auch!"),
16 new KeyValue<>("päter", "Boäh, echt! ß mal nä Nümmäh!"),