Sorry - This PR is actually for KAFKA-3430, I entered the wrong number, I have updated the title on the PR
On Thu, Apr 14, 2016 at 10:41 PM, bbejeck <g...@git.apache.org> wrote: > GitHub user bbejeck opened a pull request: > > https://github.com/apache/kafka/pull/1222 > > KAFKA-3420 Allow users to set key in KTable.toStream and in KStream. … > > … With KStream the method selectKey was added to enable getting a key > from values before perfoming aggregation-by-key operations on original > streams that have null keys. > > You can merge this pull request into a Git repository by running: > > $ git pull https://github.com/bbejeck/kafka > KAFKA-3430_allow_users_to_set_key_KTable_toStream > > Alternatively you can review and apply these changes as the patch at: > > https://github.com/apache/kafka/pull/1222.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 #1222 > > ---- > commit 44db377c9687044b00ebbdf1ef7555423c1125f2 > Author: bbejeck <bbej...@gmail.com> > Date: 2016-04-15T02:40:01Z > > KAFKA-3420 Allow users to set key in KTable.toStream and in KStream. > With KStream the method selectKey was added to enable getting a key from > values before perfoming aggregation-by-key operations on original streams > that have null keys. > > ---- > > > --- > If your project is set up for it, you can reply to this email and have your > reply appear on GitHub as well. If your project does not have this feature > enabled and wishes so, or if the feature is enabled but not working, please > contact infrastructure at infrastruct...@apache.org or file a JIRA ticket > with INFRA. > --- >