(JsonDeserializer<Word>)keySerde.deserializer(),
(JsonDeserializer<WordCounter>)valueSerde.deserializer());
- TestData.writeInputData((key, value) -> in.pipeInput(key, value));
+ TestData.injectInputMessages((key, value) -> in.pipeInput(key, value));
MultiValueMap<Word, WordCounter> receivedMessages = new LinkedMultiValueMap<>();
out
receivedMessages.add(record.key(), record.value());
});
- TestData.assertExpectedResult(receivedMessages);
+ TestData.assertExpectedMessages(receivedMessages);
}
}