From: Kai Moritz <kai@juplo.de>
Date: Sat, 15 Jun 2024 21:11:02 +0000 (+0200)
Subject: WIP: popular: 1.0.0 - Renamed packages and classes -- ALIGN
X-Git-Tag: popular-on-top10
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=4da80b47c4d86b7c309bf4bcc44acda4d40db290;p=demos%2Fkafka%2Fwordcount

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