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 Word.of("peter","Hallo"),
73 WordCount.of("peter","Hallo",1)),
75 Word.of("klaus","Müsch"),
76 WordCount.of("klaus","Müsch",1)),
78 Word.of("peter","Welt"),
79 WordCount.of("peter","Welt",1)),
81 Word.of("klaus","Müsch"),
82 WordCount.of("klaus","Müsch",2)),
85 WordCount.of("klaus","s",1)),
87 Word.of("peter","Boäh"),
88 WordCount.of("peter","Boäh",1)),
90 Word.of("peter","Welt"),
91 WordCount.of("peter","Welt",2)),
93 Word.of("peter","Boäh"),
94 WordCount.of("peter","Boäh",2)),
97 WordCount.of("klaus","s",2)),
99 Word.of("peter","Boäh"),
100 WordCount.of("peter","Boäh",3)),
102 Word.of("klaus","s"),
103 WordCount.of("klaus","s",3)),