X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Ftop10%2FTop10StreamProcessorTopologyTest.java;h=3a744ddf67f3b16375d65556b50ff01c19fd8208;hb=a01b5436757600a44b20260798d7331c7e33a851;hp=8b4a593ba7724afdd29eb2c5eb99ca354c973298;hpb=e7c52491bcef70efd85487b7469a32e832d61724;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessorTopologyTest.java b/src/test/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessorTopologyTest.java
index 8b4a593..3a744dd 100644
--- a/src/test/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessorTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessorTopologyTest.java
@@ -27,13 +27,10 @@ public class Top10StreamProcessorTopologyTest
   @Test
   public void test()
   {
-    Topology topology = CounterStreamProcessor.buildTopology(
-        IN,
-        OUT,
-        Stores.inMemoryKeyValueStore("TOPOLOGY-TEST"));
+    Topology topology = Top10StreamProcessor.buildTopology(IN, OUT);
 
-    CounterApplicationConfiguriation applicationConfiguriation =
-        new CounterApplicationConfiguriation();
+    Top10ApplicationConfiguriation applicationConfiguriation =
+        new Top10ApplicationConfiguriation();
     Properties streamProcessorProperties =
         applicationConfiguriation.streamProcessorProperties(new CounterApplicationProperties());
     Map<String, Object> propertyMap = convertToMap(streamProcessorProperties);