1 package de.juplo.kafka.wordcount.counter;
4 import java.util.function.BiConsumer;
6 import static org.assertj.core.api.Assertions.assertThat;
11 static void writeInputData(BiConsumer<String, Word> consumer)
15 Word.of("peter","Hallo"));
18 Word.of("klaus","Müsch"));
21 Word.of("peter","Welt"));
24 Word.of("klaus","Müsch"));
27 Word.of("klaus","s"));
30 Word.of("peter","Boäh"));
33 Word.of("peter","Welt"));
36 Word.of("peter","Boäh"));
39 Word.of("klaus","s"));
42 Word.of("peter","Boäh"));
45 Word.of("klaus","s"));
48 static void assertExpectedResult(List<Message> receivedMessages)
50 assertThat(receivedMessages).hasSize(11);
51 assertThat(receivedMessages).containsSubsequence(
52 expectedMessages[0]); // Hallo
53 assertThat(receivedMessages).containsSubsequence(
55 expectedMessages[3]); // Müsch
56 assertThat(receivedMessages).containsSubsequence(
59 assertThat(receivedMessages).containsSubsequence(
62 expectedMessages[10]); // s
63 assertThat(receivedMessages).containsSubsequence(
66 expectedMessages[9]); // Boäh
69 static Message[] expectedMessages =
72 "{\"user\":\"peter\",\"word\":\"Hallo\"}",
73 "{\"user\":\"peter\",\"word\":\"Hallo\",\"count\":1}"),
75 "{\"user\":\"klaus\",\"word\":\"Müsch\"}",
76 "{\"user\":\"klaus\",\"word\":\"Müsch\",\"count\":1}"),
78 "{\"user\":\"peter\",\"word\":\"Welt\"}",
79 "{\"user\":\"peter\",\"word\":\"Welt\",\"count\":1}"),
81 "{\"user\":\"klaus\",\"word\":\"Müsch\"}",
82 "{\"user\":\"klaus\",\"word\":\"Müsch\",\"count\":2}"),
84 "{\"user\":\"klaus\",\"word\":\"s\"}",
85 "{\"user\":\"klaus\",\"word\":\"s\",\"count\":1}"),
87 "{\"user\":\"peter\",\"word\":\"Boäh\"}",
88 "{\"user\":\"peter\",\"word\":\"Boäh\",\"count\":1}"),
90 "{\"user\":\"peter\",\"word\":\"Welt\"}",
91 "{\"user\":\"peter\",\"word\":\"Welt\",\"count\":2}"),
93 "{\"user\":\"peter\",\"word\":\"Boäh\"}",
94 "{\"user\":\"peter\",\"word\":\"Boäh\",\"count\":2}"),
96 "{\"user\":\"klaus\",\"word\":\"s\"}",
97 "{\"user\":\"klaus\",\"word\":\"s\",\"count\":2}"),
99 "{\"user\":\"peter\",\"word\":\"Boäh\"}",
100 "{\"user\":\"peter\",\"word\":\"Boäh\",\"count\":3}"),
102 "{\"user\":\"klaus\",\"word\":\"s\"}",
103 "{\"user\":\"klaus\",\"word\":\"s\",\"count\":3}"),