X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FTestData.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FTestData.java;h=8c343d5e6d00136de545568b5d2705b24a7a3a55;hb=5283e1688c50764d828f83f7d58d4cf1c7e56cf9;hp=e2bf9ccb67c37f35b7a9c6ba56c47342c9e4e9e7;hpb=c9663d885810c20447e31d48f1d5b3de3b90e229;p=demos%2Fkafka%2Fwordcount

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
--- 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[]
 	{