public static <K, V> Consumed<K, V> with(final Serde<K> keySerde,
                                             final Serde<V> valueSerde,
                                             final TimestampExtractor timestampExtractor,
                                             final Topology.AutoOffsetReset resetPolicy) {
        return new Consumed<>(keySerde, valueSerde, timestampExtractor, resetPolicy, null);
    }
Create an instance of {@link Consumed} with the supplied arguments. {@code null} values are acceptable.

@param keySerde
       the key serde. If {@code null} the default key serde from config will be used
@param valueSerde
       the value serde. If {@code null} the default value serde from config will be used
@param timestampExtractor
       the timestamp extractor to used. If {@code null} the default timestamp extractor from config will be used
@param resetPolicy
       the offset reset policy to be used. If {@code null} the default reset policy from config will be used

@param <K> key type
@param <V> value type

@return a new instance of {@link Consumed}
streams/src/main/java/org/apache/kafka/streams/kstream/Consumed.java