Description
Add the following classes and methods to KStream
KGroupedStream<K, V> groupByKey(final Serialized<K, V> serialized)
<KR> KGroupedStream<KR, V> groupBy(final KeyValueMapper<? super K, ? super V, KR> selector, Serialized<KR, V> serialized)
public class Serialized<K, V> { public static <K, V> Serialized<K, V> with(final Serde<K> keySerde, final Serde<V> valueSerde) public Serialized<K, V> withKeySerde(final Serde<K> keySerde) public Serialized<K, V> withValueSerde(final Serde valueSerde) }
Attachments
Issue Links
- is duplicated by
-
KAFKA-5652 Add new api methods to KStream
-
- Resolved
-
- links to