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, String> consumer)
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 "{\"username\":\"peter\",\"word\":\"Hallo\"}",
75 "{\"username\":\"klaus\",\"word\":\"Müsch\"}",
78 "{\"username\":\"peter\",\"word\":\"Welt\"}",
81 "{\"username\":\"klaus\",\"word\":\"Müsch\"}",
84 "{\"username\":\"klaus\",\"word\":\"s\"}",
87 "{\"username\":\"peter\",\"word\":\"Boäh\"}",
90 "{\"username\":\"peter\",\"word\":\"Welt\"}",
93 "{\"username\":\"peter\",\"word\":\"Boäh\"}",
96 "{\"username\":\"klaus\",\"word\":\"s\"}",
99 "{\"username\":\"peter\",\"word\":\"Boäh\"}",
102 "{\"username\":\"klaus\",\"word\":\"s\"}",