From: Kai Moritz <kai@juplo.de>
Date: Tue, 14 May 2024 22:51:13 +0000 (+0200)
Subject: WIP
X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Fwordcount;a=commitdiff_plain;h=refs%2Fheads%2Ftop10

WIP
---

diff --git a/src/main/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessor.java b/src/main/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessor.java
index 2b2cf93..a3900bf 100644
--- a/src/main/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessor.java
+++ b/src/main/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessor.java
@@ -39,7 +39,7 @@ public class Top10StreamProcessor
 				.groupByKey()
 				.aggregate(
 						() -> new Ranking(),
-						(user, entry, ranking) ->ranking.add(entry))
+						(user, entry, ranking) -> ranking.add(entry))
 				.toStream()
 				.to(outputTopic);
 
diff --git a/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java b/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
index a284a5d..f453dbd 100644
--- a/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
+++ b/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
@@ -97,8 +97,8 @@ class TestData
 					"peter",
 					Ranking.of(
 							Entry.of("Boäh", 1l),
-							Entry.of("Hallo", 1l),
-							Entry.of("Welt", 1l))),
+							Entry.of("Welt", 1l),
+							Entry.of("Hallo", 1l))),
 			KeyValue.pair( // 6
 					"peter",
 					Ranking.of(
@@ -108,8 +108,8 @@ class TestData
 			KeyValue.pair( // 7
 					"peter",
 					Ranking.of(
-							Entry.of("Welt", 2l),
 							Entry.of("Boäh", 2l),
+							Entry.of("Welt", 2l),
 							Entry.of("Hallo", 1l))),
 			KeyValue.pair( // 8
 					"klaus",