GitHub user KyleWinkelman opened a pull request:
https://github.com/apache/kafka/pull/2633
MINOR: Add simplified aggregate methods to KGroupedStream
Currently the KGroupedStream aggregate methods requires users to supply
(Serde) null if they intend to use the default value serde. This pull request
aligns the methods available in KGroupedStream with those in KGroupedTable
allowing users to not supply a (Serde) null when using the default value serde.
I added the same disclaimer in the javadocs as that found in the
KGroupedTable informing the user to use the other available methods if the
result value type doesn't match the default value serde.
Unit tests were updated to go through these methods instead of supplying a
Serdes.String() which doesn't get used.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/KyleWinkelman/kafka expand-kgroupedstream
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2633.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 #2633
----
commit f65bbd990ffbb779636642740c802cd7f082677e
Author: Kyle Winkelman <[email protected]>
Date: 2017-03-03T00:28:14Z
MINOR: Align KGroupedStream aggregate methods with KGroupedTable aggregate
methods. Allowing users to avoid passing a null Serde when using the
default value serde.
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
