- Recording recording;
-
- recording = new Recording();
- recording.setUser("peter");
- recording.setSentence("Hallo Welt!");
- consumer.accept(recording.getUser(), recording);
-
- recording = new Recording();
- recording.setUser("klaus");
- recording.setSentence("Müsch gäb's auch!");
- consumer.accept(recording.getUser(), recording);
-
- recording = new Recording();
- recording.setUser("peter");
- recording.setSentence("Boäh, echt! ß mal nä Nümmäh!");
- consumer.accept(recording.getUser(), recording);
- }
-
- @Test
- void testSendMessage() throws Exception
- {
- writeInputData((user, recording) -> kafkaTemplate.send(TOPIC_IN, user, recording));
-
- await("Expexted converted data")
- .atMost(Duration.ofSeconds(5))
- .untilAsserted(() ->
- assertExpectedMessages(consumer.getReceivedMessages()));
- }
-
+ new KeyValue<>(
+ PETER,
+ TestRecording.of(PETER, "Hallo Welt!")),
+ new KeyValue<>(
+ KLAUS,
+ TestRecording.of(KLAUS, "Müsch gäb's auch!")),
+ new KeyValue<>(
+ PETER,
+ TestRecording.of(PETER, "Boäh, echt! ß mal nä Nümmäh!")),
+ };