/**
* Options for consuming a topic as a KStream or KTable
*/
public class Consumed<K, V> {
public static <K, V> Consumed<K, V> with(final Serde<K> keySerde, final Serde<V> valueSerde, final TimestampExtractor extractor, final Topology.AutoOffsetReset resetPolicy)
public static <K, V> Consumed<K, V> with(final Serde<K> keySerde, final Serde<V> valueSerde)
public static <K, V> Consumed<K, V> with(final TimestampExtractor extractor)
public static <K, V> Consumed<K, V> with(final Topology.AutoOffsetReset resetPolicy)
public Consumed<K, V> withKeySerde(final Serde<K> keySerde)
public Consumed<K, V> withValueSerde(final Serde<V> valueSerde)
public Consumed<K, V> withTimestampExtractor(final TimestampExtractor timestampExtractor)
public Consumed<K, V> withOffsetResetPolicy(final Topology.AutoOffsetReset resetPolicy)
} |