import org.springframework.util.MultiValueMap;
import java.time.Duration;
+import java.util.stream.Stream;
import static de.juplo.kafka.wordcount.counter.CounterApplicationIT.TOPIC_IN;
import static de.juplo.kafka.wordcount.counter.CounterApplicationIT.TOPIC_OUT;
@Test
void testSendMessage()
{
- TestData.writeInputData((key, value) -> kafkaTemplate.send(TOPIC_IN, key, value));
+ Stream
+ .of(TestData.INPUT_MESSAGES)
+ .forEach(word -> kafkaTemplate.send(TOPIC_IN, word.getUser(), word));
- await("Expexted converted data")
+ await("Expected messages")
.atMost(Duration.ofSeconds(10))
- .untilAsserted(() -> TestData.assertExpectedResult(consumer.getReceivedMessages()));
+ .untilAsserted(() -> TestData.assertExpectedMessages(consumer.getReceivedMessages()));
}