WIP: popular: 1.0.0 - Renamed packages and classes -- ALIGN

diff --git a/src/main/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessor.java b/src/main/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessor.java
index 4320d35..9952e2e 100644 (file)
--- a/src/main/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessor.java
+++ b/src/main/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessor.java
@@ -20,7 +20,6 @@ public class PopularStreamProcessor
 
        public PopularStreamProcessor(
                        String inputTopic,
-                       String outputTopic,
                        Properties props,
                        KeyValueBytesStoreSupplier storeSupplier)
        {

diff --git a/src/test/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessorTopologyTest.java b/src/test/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessorTopologyTest.java
index 0588b00..8dd9915 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessorTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessorTopologyTest.java
@@ -2,8 +2,6 @@ package de.juplo.kafka.wordcount.popular;
 
 import de.juplo.kafka.wordcount.counter.TestCounter;
 import de.juplo.kafka.wordcount.counter.TestWord;
-import de.juplo.kafka.wordcount.query.TestRanking;
-import de.juplo.kafka.wordcount.query.TestUser;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.streams.TestInputTopic;
 import org.apache.kafka.streams.TestOutputTopic;
@@ -34,7 +32,6 @@ public class PopularStreamProcessorTopologyTest
 
   TopologyTestDriver testDriver;
   TestInputTopic<TestWord, TestCounter> in;
-  TestOutputTopic<TestUser, TestRanking> out;
 
 
   @BeforeEach
@@ -42,7 +39,6 @@ public class PopularStreamProcessorTopologyTest
   {
     Topology topology = PopularStreamProcessor.buildTopology(
         IN,
-        OUT,
         Stores.inMemoryKeyValueStore(STORE_NAME));
 
     testDriver = new TopologyTestDriver(topology, serializationConfig());

diff --git a/src/test/java/de/juplo/kafka/wordcount/query/TestRanking.java b/src/test/java/de/juplo/kafka/wordcount/query/TestRanking.java
index efad48b..a9b9d98 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/query/TestRanking.java
+++ b/src/test/java/de/juplo/kafka/wordcount/query/TestRanking.java
@@ -1,6 +1,6 @@
 package de.juplo.kafka.wordcount.query;
 
-import de.juplo.kafka.wordcount.top10.Entry;
+import de.juplo.kafka.wordcount.popular.Entry;
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;
 import lombok.Data;