public static <T> Serde<Windowed<T>> timeWindowedSerdeFrom(final Class<T> type, final long windowSize) {
        return new TimeWindowedSerde<>(Serdes.serdeFrom(type), windowSize);
    }
Construct a {@code TimeWindowedSerde} object to deserialize changelog topic
for the specified inner class type and window size.
streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java