WIP

[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / top10 / TestData.java

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 fb030e3..a284a5d 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
+++ b/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
@@ -56,77 +56,73 @@ class TestData
        {
                assertThat(receivedMessages).hasSize(11);
                assertThat(receivedMessages).containsSubsequence(
-                               expectedMessages[0]); // Hallo
-               assertThat(receivedMessages).containsSubsequence(
-                               expectedMessages[1],
-                               expectedMessages[3]); // Müsch
-               assertThat(receivedMessages).containsSubsequence(
+                               expectedMessages[0],
                                expectedMessages[2],
-                               expectedMessages[6]);
+                               expectedMessages[5],
+                               expectedMessages[6],
+                               expectedMessages[7]); // peter
                assertThat(receivedMessages).containsSubsequence(
+                               expectedMessages[1],
+                               expectedMessages[3],
                                expectedMessages[4],
                                expectedMessages[8],
-                               expectedMessages[10]); // s
-               assertThat(receivedMessages).containsSubsequence(
-                               expectedMessages[5],
-                               expectedMessages[7],
-                               expectedMessages[9]); // Boäh
+                               expectedMessages[10]); // klaus
        }
 
        static KeyValue<String, Ranking>[] expectedMessages = new KeyValue[]
        {
-                       KeyValue.pair(
+                       KeyValue.pair( // 0
                                        "peter",
                                        Ranking.of(
                                                        Entry.of("Hallo", 1l))),
-                       KeyValue.pair(
+                       KeyValue.pair( // 1
                                        "klaus",
                                        Ranking.of(
                                                        Entry.of("Müsch", 1l))),
-                       KeyValue.pair(
+                       KeyValue.pair( // 2
                                        "peter",
                                        Ranking.of(
-                                                       Entry.of("Hallo", 1l),
-                                                       Entry.of("Welt", 1l))),
-                       KeyValue.pair(
+                                                       Entry.of("Welt", 1l),
+                                                       Entry.of("Hallo", 1l))),
+                       KeyValue.pair( // 3
                                        "klaus",
                                        Ranking.of(
                                                        Entry.of("Müsch", 2l))),
-                       KeyValue.pair(
+                       KeyValue.pair( // 4
                                        "klaus",
                                        Ranking.of(
                                                        Entry.of("Müsch", 2l),
                                                        Entry.of("s", 1l))),
-                       KeyValue.pair(
+                       KeyValue.pair( // 5
                                        "peter",
                                        Ranking.of(
+                                                       Entry.of("Boäh", 1l),
                                                        Entry.of("Hallo", 1l),
-                                                       Entry.of("Welt", 1l),
-                                                       Entry.of("Boäh", 1l))),
-                       KeyValue.pair(
+                                                       Entry.of("Welt", 1l))),
+                       KeyValue.pair( // 6
                                        "peter",
                                        Ranking.of(
                                                        Entry.of("Welt", 2l),
-                                                       Entry.of("Hallo", 1l),
-                                                       Entry.of("Boäh", 1l))),
-                       KeyValue.pair(
+                                                       Entry.of("Boäh", 1l),
+                                                       Entry.of("Hallo", 1l))),
+                       KeyValue.pair( // 7
                                        "peter",
                                        Ranking.of(
                                                        Entry.of("Welt", 2l),
                                                        Entry.of("Boäh", 2l),
                                                        Entry.of("Hallo", 1l))),
-                       KeyValue.pair(
+                       KeyValue.pair( // 8
                                        "klaus",
                                        Ranking.of(
-                                                       Entry.of("Müsch", 2l),
-                                                       Entry.of("s", 2l))),
-                       KeyValue.pair(
+                                                       Entry.of("s", 2l),
+                                                       Entry.of("Müsch", 2l))),
+                       KeyValue.pair( // 9
                                        "peter",
                                        Ranking.of(
                                                        Entry.of("Boäh", 3l),
                                                        Entry.of("Welt", 2l),
                                                        Entry.of("Hallo", 1l))),
-                       KeyValue.pair(
+                       KeyValue.pair( // 10
                                        "klaus",
                                        Ranking.of(
                                                        Entry.of("s", 3l),