TopologyTestDriver testDriver;
TestInputTopic<Key, Entry> in;
- TestOutputTopic<String, Ranking> out;
+ TestOutputTopic<User, Ranking> out;
@BeforeEach
out = testDriver.createOutputTopic(
OUT,
- (JsonDeserializer<String>)keySerde.deserializer(),
+ (JsonDeserializer<User>)keySerde.deserializer(),
(JsonDeserializer<Ranking>)valueSerde.deserializer());
}
Key.of(kv.key.getUser(), kv.key.getWord()),
Entry.of(kv.value.getWord(), kv.value.getCounter())));
- MultiValueMap<String, Ranking> receivedMessages = new LinkedMultiValueMap<>();
+ MultiValueMap<User, Ranking> receivedMessages = new LinkedMultiValueMap<>();
out
.readRecordsToList()
.forEach(record ->