From 4da80b47c4d86b7c309bf4bcc44acda4d40db290 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 15 Jun 2024 23:11:02 +0200
Subject: [PATCH] WIP: popular: 1.0.0 - Renamed packages and classes -- ALIGN

---
 .../juplo/kafka/wordcount/popular/PopularStreamProcessor.java | 1 -
 .../wordcount/popular/PopularStreamProcessorTopologyTest.java | 4 ----
 src/test/java/de/juplo/kafka/wordcount/query/TestRanking.java | 2 +-
 3 files changed, 1 insertion(+), 6 deletions(-)

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
--- 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
--- 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
--- 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;
-- 
2.20.1