import org.apache.kafka.streams.KeyValue;
+import java.util.stream.Stream;
+
class TestData
{
static final String PETER = "päter";
static final String KLAUS = "klühs";
- static final KeyValue<String, String>[] INPUT_MESSAGES = new KeyValue[]
+ static final Stream<KeyValue<String, String>> getInputMessages()
+ {
+ return Stream.of(INPUT_MESSAGES);
+ }
+
+ private static final KeyValue<String, String>[] INPUT_MESSAGES = new KeyValue[]
{
new KeyValue<>("päter", "Hall° Wält?¢*&%€!"),
new KeyValue<>("päter", "Hallo Welt!"),