From 20da5a144f8478fd7a00081c39f34a6670a68101 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 15 May 2024 00:33:34 +0200 Subject: [PATCH] WIP --- .../juplo/kafka/wordcount/top10/TestData.java | 56 +++++++++---------- 1 file changed, 26 insertions(+), 30 deletions(-) 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 --- 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[] 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), -- 2.20.1