/**
* Optional arguments that can be specified when doing to and through operations
*/
public static <K, V> Produced<K, V> with(final Serde<K> keySerde, final Serde<V> valueSerde)
public static <K, V> Produced<K, V> with(final Serde<K> keySerde, final Serde<V> valueSerde, final StreamPartitioner<K, V> partitioner)
public static <K, V> Produced<K, V> keySerde(final Serde<K> keySerde)
public static <K, V> Produced<K, V> valueSerde(final Serde<V> valueSerde)
public static <K, V> Produced<K, V> streamPartitioner(final StreamPartitioner<K, V> partitioner)
public Produced<K, V> withStreamPartitioner(final StreamPartitioner<K, V> partitioner)
public Produced<K, V> withValueSerde(final Serde<V> valueSerde)
public Produced<K, V> withKeySerde(final Serde<K> keySerde)
public Serde<K> keySerde()
public Serde<K> valueSerde()
public StreamPartitioner<K, V> streamPartitioner() |