X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterStreamProcessorTopologyTest.java;h=902e93f379566a8a973f915a63e3f26d1529f7be;hb=f9106e5166ce84caa2a910aa21fb41efaebcc73f;hp=fe85dc49d2d23333ba89757801f82fddd3ce26c7;hpb=0de33af47b76eaad1a2218dc88ae8a53b0235979;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 fe85dc4..902e93f 100644 --- a/src/test/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessorTopologyTest.java +++ b/src/test/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessorTopologyTest.java @@ -8,6 +8,7 @@ import org.apache.kafka.streams.Topology; import org.apache.kafka.streams.TopologyTestDriver; import org.apache.kafka.streams.state.Stores; import org.junit.jupiter.api.Test; +import org.springframework.kafka.support.serializer.JsonSerializer; import java.util.List; import java.util.Properties; @@ -33,10 +34,10 @@ public class CounterStreamProcessorTopologyTest TopologyTestDriver testDriver = new TopologyTestDriver(topology, streamProcessorProperties); - TestInputTopic in = testDriver.createInputTopic( + TestInputTopic in = testDriver.createInputTopic( IN, - new StringSerializer(), - new StringSerializer()); + new JsonSerializer<>(), + new JsonSerializer<>()); TestOutputTopic out = testDriver.createOutputTopic( OUT,