[ https://issues.apache.org/jira/browse/KAFKA-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149394#comment-16149394 ]
ASF GitHub Bot commented on KAFKA-5817: --------------------------------------- GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3772 KAFKA-5817: Add Serialized class and overloads to KStream#groupBy and KStream#groupByKey Part of KIP-182 - Add the `Serialized` class - implement overloads of `KStream#groupByKey` and KStream#groupBy` - deprecate existing methods that have more than default arguments You can merge this pull request into a Git repository by running: $ git pull https://github.com/dguy/kafka kafka-5817 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3772.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3772 ---- commit 2ccec406738a91ffbd091632221299d794e8d035 Author: Damian Guy <damian....@gmail.com> Date: 2017-08-31T18:24:10Z Add Serialized class and overloads to KStream#groupBy and KStream#groupByKey ---- > Add Serialized class and KStream groupBy and groupByKey overloads > ----------------------------------------------------------------- > > Key: KAFKA-5817 > URL: https://issues.apache.org/jira/browse/KAFKA-5817 > Project: Kafka > Issue Type: Sub-task > Components: streams > Reporter: Damian Guy > Assignee: Damian Guy > > 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)}} > {code} > 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) > } > {code} -- This message was sent by Atlassian JIRA (v6.4.14#64029)