WIP

diff --git a/src/test/java/de/juplo/kafka/wordcount/stats/TestData.java b/src/test/java/de/juplo/kafka/wordcount/stats/TestData.java
index 50ed697..28dfe71 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/stats/TestData.java
+++ b/src/test/java/de/juplo/kafka/wordcount/stats/TestData.java
@@ -17,6 +17,7 @@ class TestData
 {
        static final TestUser PETER = TestUser.of(StatisticsType.POPULAR.name(), "peter");
        static final TestUser KLAUS = TestUser.of(StatisticsType.POPULAR.name(), "klaus");
+       static final TestUser OTHER_CHANNEL = TestUser.of("COUNTER", "klaus");
 
        static final Stream<KeyValue<TestUser, TestRanking>> getTop10Messages()
        {
@@ -79,6 +80,10 @@ class TestData
                                        PETER,
                                        TestRanking.of(
                                                        TestEntry.of("Hallo", 1l))),
+                       KeyValue.pair( // BOOM!
+                                       OTHER_CHANNEL,
+                                       TestRanking.of(
+                                                       TestEntry.of("Müsch", 1l))),
                        KeyValue.pair( // 1
                                        KLAUS,
                                        TestRanking.of(
@@ -120,6 +125,11 @@ class TestData
                                        TestRanking.of(
                                                        TestEntry.of("Müsch", 2l),
                                                        TestEntry.of("s", 2l))),
+                       KeyValue.pair( // BOOM!
+                                       KLAUS,
+                                       TestRanking.of(
+                                                       TestEntry.of("Müsch", 2l),
+                                                       TestEntry.of("s", 2l))),
                        KeyValue.pair( // 9
                                        PETER,
                                        TestRanking.of(