1 package de.juplo.kafka.wordcount.top10;
4 import java.util.function.BiConsumer;
6 import static org.assertj.core.api.Assertions.assertThat;
11 static void writeInputData(BiConsumer<String, String> consumer)
15 "{\"user\":\"peter\",\"word\":\"Hallo\"}");
18 "{\"user\":\"klaus\",\"word\":\"Müsch\"}");
21 "{\"user\":\"peter\",\"word\":\"Welt\"}");
24 "{\"user\":\"klaus\",\"word\":\"Müsch\"}");
27 "{\"user\":\"klaus\",\"word\":\"s\"}");
30 "{\"user\":\"peter\",\"word\":\"Boäh\"}");
33 "{\"user\":\"peter\",\"word\":\"Welt\"}");
36 "{\"user\":\"peter\",\"word\":\"Boäh\"}");
39 "{\"user\":\"klaus\",\"word\":\"s\"}");
42 "{\"user\":\"peter\",\"word\":\"Boäh\"}");
45 "{\"user\":\"klaus\",\"word\":\"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}"),