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 (file)
--- 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(),
                                .groupByKey()
                                .aggregate(
                                                () -> new Ranking(),

-                                               (user, entry, ranking) ->ranking.add(entry))
+                                               (user, entry, ranking) -> ranking.add(entry))

                                .toStream()
                                .to(outputTopic);
 
                                .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 (file)
--- 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),
                                        "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(
                        KeyValue.pair( // 6
                                        "peter",
                                        Ranking.of(


@@ -108,8 +108,8 @@ class TestData
                        KeyValue.pair( // 7
                                        "peter",
                                        Ranking.of(
                        KeyValue.pair( // 7
                                        "peter",
                                        Ranking.of(

-                                                       Entry.of("Welt", 2l),

                                                        Entry.of("Boäh", 2l),
                                                        Entry.of("Boäh", 2l),

+                                                       Entry.of("Welt", 2l),

                                                        Entry.of("Hallo", 1l))),
                        KeyValue.pair( // 8
                                        "klaus",
                                                        Entry.of("Hallo", 1l))),
                        KeyValue.pair( // 8
                                        "klaus",