X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterStreamProcessorTopologyTest.java;h=16cf5d287cb955a868849aa0ca1f456fa8c28523;hb=7474f0e1fc7028e60ef9526fec86bfb8824c6517;hp=5b9f3658adb034d632150ac1a1220953a5c703a2;hpb=34105430df56c86f6d18329feb5dedd45fe42e15;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessorTopologyTest.java b/src/test/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessorTopologyTest.java
index 5b9f365..16cf5d2 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessorTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessorTopologyTest.java
@@ -59,7 +59,7 @@ public class CounterStreamProcessorTopologyTest
         (JsonDeserializer<Word>)keySerde.deserializer(),
         (JsonDeserializer<WordCounter>)valueSerde.deserializer());
 
-    TestData.writeInputData((key, value) -> in.pipeInput(key, value));
+    TestData.injectInputMessages((key, value) -> in.pipeInput(key, value));
 
     MultiValueMap<Word, WordCounter> receivedMessages = new LinkedMultiValueMap<>();
     out
@@ -75,6 +75,6 @@ public class CounterStreamProcessorTopologyTest
           receivedMessages.add(record.key(), record.value());
         });
 
-    TestData.assertExpectedResult(receivedMessages);
+    TestData.assertExpectedMessages(receivedMessages);
   }
 }