import org.springframework.util.MultiValueMap;
import java.util.Map;
-import java.util.stream.Stream;
import static de.juplo.kafka.wordcount.top10.Top10ApplicationConfiguration.serializationConfig;
@Test
public void test()
{
- Stream
- .of(TestData.INPUT_MESSAGES)
+ TestData
+ .getInputMessages()
.forEach(kv -> in.pipeInput(kv.key, kv.value));
MultiValueMap<TestUser, TestRanking> receivedMessages = new LinkedMultiValueMap<>();