import java.time.Duration;
import java.util.List;
-import java.util.stream.Stream;
import static de.juplo.kafka.wordcount.recorder.RecorderApplicationIT.TOPIC_OUT;
import static org.assertj.core.api.Assertions.assertThat;
{
MultiValueMap<String, TestRecording> recordings = new LinkedMultiValueMap<>();
- Stream
- .of(TestData.INPUT_MESSAGES)
+ TestData
+ .getInputMessages()
.forEach(kv ->
{
sendRedording(kv.key, kv.value);