X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterStreamProcessorTopologyTest.java;h=16cf5d287cb955a868849aa0ca1f456fa8c28523;hb=ac64aac16d87b469f7772463e70f38db95e9943d;hp=5b9f3658adb034d632150ac1a1220953a5c703a2;hpb=f08dc87a018fb2cd84de1a274c20fb9f4487b7a0;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)keySerde.deserializer(), (JsonDeserializer)valueSerde.deserializer()); - TestData.writeInputData((key, value) -> in.pipeInput(key, value)); + TestData.injectInputMessages((key, value) -> in.pipeInput(key, value)); MultiValueMap receivedMessages = new LinkedMultiValueMap<>(); out @@ -75,6 +75,6 @@ public class CounterStreamProcessorTopologyTest receivedMessages.add(record.key(), record.value()); }); - TestData.assertExpectedResult(receivedMessages); + TestData.assertExpectedMessages(receivedMessages); } }