X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Ftop10%2FTestData.java;h=e0c53df8fa6caade6f8df78c5deb868fcbc74a65;hb=a7c3a493ee3b6ec8629eb749d1ce4ed059f4cff9;hp=a4f79ac72c882fee5a0a9e444f5f570dfe11e15c;hpb=fa19058953b388f893255d2bcc9351ac9eb3328b;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java b/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
index a4f79ac..e0c53df 100644
--- a/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
+++ b/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
@@ -2,16 +2,11 @@ package de.juplo.kafka.wordcount.top10;
 
 import de.juplo.kafka.wordcount.counter.TestCounter;
 import de.juplo.kafka.wordcount.counter.TestWord;
-import org.apache.kafka.common.header.Header;
-import org.apache.kafka.common.header.Headers;
 import org.apache.kafka.streams.KeyValue;
 import org.apache.kafka.streams.state.ReadOnlyKeyValueStore;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 
-import java.util.Map;
-import java.util.Properties;
-import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import static org.assertj.core.api.Assertions.assertThat;
@@ -177,29 +172,4 @@ class TestData
 				.forEach(keyValue -> expectedMessages.add(keyValue.key, keyValue.value));
 		return expectedMessages;
 	}
-
-	static Map<String, Object> convertToMap(Properties properties)
-	{
-		return properties
-				.entrySet()
-				.stream()
-				.collect(
-						Collectors.toMap(
-								entry -> (String)entry.getKey(),
-								entry -> entry.getValue()
-						));
-	}
-
-	static String parseHeader(Headers headers, String key)
-	{
-		Header header = headers.lastHeader(key);
-		if (header == null)
-		{
-			return key + "=null";
-		}
-		else
-		{
-			return key + "=" + new String(header.value());
-		}
-	}
 }