juplo.de Git - demos/kafka/wordcount/blob - src/test/java/de/juplo/kafka/wordcount/recorder/TestData.java

   1 package de.juplo.kafka.wordcount.recorder;
   2
   3 import org.apache.kafka.streams.KeyValue;
   4
   5 import java.util.stream.Stream;
   6
   7
   8 class TestData
   9 {
  10         static final String PETER = "päter";
  11         static final String KLAUS = "klühs";
  12
  13         static final Stream<KeyValue<String, String>> getInputMessages()
  14         {
  15                 return Stream.of(INPUT_MESSAGES);
  16         }
  17
  18         private static final KeyValue<String, String>[] INPUT_MESSAGES = new KeyValue[]
  19         {
  20                         new KeyValue<>("päter", "Hall° Wält?¢*&%€!"),
  21                         new KeyValue<>("päter", "Hallo Welt!"),
  22                         new KeyValue<>("klühs", "Müsch gäb's auch!"),
  23                         new KeyValue<>("päter", "Boäh, echt! ß mal nä Nümmäh!"),
  24         };
  25 }