From 2bfe11dba9a4fbe2a8db4ad541a3a2774259886c Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Wed, 15 May 2024 00:51:13 +0200
Subject: [PATCH] WIP

---
 .../juplo/kafka/wordcount/top10/Top10StreamProcessor.java   | 2 +-
 src/test/java/de/juplo/kafka/wordcount/top10/TestData.java  | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

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",
-- 
2.20.1