import org.springframework.util.MultiValueMap;
import java.time.Duration;
-import java.util.stream.Stream;
import static de.juplo.kafka.wordcount.splitter.SplitterApplicationIT.TOPIC_IN;
import static de.juplo.kafka.wordcount.splitter.SplitterApplicationIT.TOPIC_OUT;
public static void testSendMessage(
@Autowired KafkaTemplate<String, TestRecording> kafkaTemplate)
{
- Stream
- .of(TestData.INPUT_MESSAGES)
+ TestData
+ .getInputMessages()
.forEach(kv ->
{
try