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
   6 class TestData
   7 {
   8         static final String PETER = "päter";
   9         static final String KLAUS = "klühs";
  10
  11         static final KeyValue<String, String>[] INPUT_MESSAGES = new KeyValue[]
  12         {
  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!"),
  17         };
  18 }