package de.juplo.kafka.wordcount.counter;
-import org.apache.kafka.streams.TestInputTopic;
-import org.apache.kafka.streams.TestOutputTopic;
-import org.apache.kafka.streams.Topology;
-import org.apache.kafka.streams.TopologyTestDriver;
+import org.apache.kafka.streams.*;
import org.apache.kafka.streams.state.Stores;
import org.junit.jupiter.api.Test;
import org.springframework.kafka.support.serializer.JsonDeserializer;
TestData.writeInputData((key, value) -> in.pipeInput(key, value));
- List<Message> receivedMessages = out
+ List<KeyValue<Word,WordCount>> receivedMessages = out
.readRecordsToList()
.stream()
- .map(record -> Message.of(record.key(), record.value()))
+ .map(record -> KeyValue.pair(record.key(), record.value()))
.toList();
TestData.assertExpectedResult(receivedMessages);