@Test
void testSendMessage()
{
- TestData.writeInputData((key, value) -> kafkaTemplate.send(TOPIC_IN, key, value));
+ TestData.injectInputMessages((key, value) -> kafkaTemplate.send(TOPIC_IN, key, value));
- await("Expexted converted data")
+ await("Expected messages")
.atMost(Duration.ofSeconds(10))
- .untilAsserted(() -> TestData.assertExpectedResult(consumer.getReceivedMessages()));
+ .untilAsserted(() -> TestData.assertExpectedMessages(consumer.getReceivedMessages()));
}