[KAFKA-5817] Add Serialized class and KStream groupBy and groupByKey overloads

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Component/s: streams
• Assignee: Damian Guy
• Reporter: Damian Guy
• Created: 31/Aug/17 17:40
• Updated: 11/Sep/17 20:08
• Resolved: 06/Sep/17 09:43

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)
}

Issue Links

• is duplicated by: KAFKA-5652 Add new api methods to KStream
• links to: GitHub Pull Request #3772
• links to: GitHub Pull Request #3825