splitter: 1.2.0 - Refined creation of input in `SplitterApplicationIT`

[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / splitter / TestData.java

diff --git a/src/test/java/de/juplo/kafka/wordcount/splitter/TestData.java b/src/test/java/de/juplo/kafka/wordcount/splitter/TestData.java
index e2bf9cc..8c343d5 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/splitter/TestData.java
+++ b/src/test/java/de/juplo/kafka/wordcount/splitter/TestData.java
@@ -7,7 +7,6 @@ import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 
 import java.time.Duration;
-import java.util.function.BiConsumer;
 import java.util.stream.Stream;
 
 import static org.assertj.core.api.Assertions.assertThat;
@@ -19,12 +18,6 @@ public class TestData
        static final String PETER = "peter";
        static final String KLAUS = "klaus";
 
-       static void writeInputData(BiConsumer<String, TestRecording> consumer)
-       {
-               Stream
-                               .of(INPUT_MESSAGES)
-                               .forEach(kv -> consumer.accept(kv.key, kv.value));
-       }
 
        static final KeyValue<String, TestRecording>[] INPUT_MESSAGES = new KeyValue[]
        {