-import org.apache.kafka.streams.*;
+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.state.Stores;
import org.junit.jupiter.api.Test;
import org.springframework.kafka.support.serializer.JsonDeserializer;
import org.springframework.kafka.support.serializer.JsonSerde;
import org.springframework.kafka.support.serializer.JsonSerializer;
import org.apache.kafka.streams.state.Stores;
import org.junit.jupiter.api.Test;
import org.springframework.kafka.support.serializer.JsonDeserializer;
import org.springframework.kafka.support.serializer.JsonSerde;
import org.springframework.kafka.support.serializer.JsonSerializer;
(JsonDeserializer<Word>)keySerde.deserializer(),
(JsonDeserializer<WordCounter>)valueSerde.deserializer());
(JsonDeserializer<Word>)keySerde.deserializer(),
(JsonDeserializer<WordCounter>)valueSerde.deserializer());
record.value(),
parseHeader(record.headers(), KEY_DEFAULT_CLASSID_FIELD_NAME),
parseHeader(record.headers(), DEFAULT_CLASSID_FIELD_NAME));
record.value(),
parseHeader(record.headers(), KEY_DEFAULT_CLASSID_FIELD_NAME),
parseHeader(record.headers(), DEFAULT_CLASSID_FIELD_NAME));