GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2832
KAFKA-5045: KTable cleanup [WiP] You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-5045-ktable Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2832.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 #2832 ---- commit c44c1868c81f2055dfd6185af609e5664cfff01e Author: Eno Thereska <eno.there...@gmail.com> Date: 2017-04-10T12:57:15Z Pass on KStreamBuilder commit c4ca09ab8194cf58e20161d6a17e8c7059448933 Author: Eno Thereska <eno.there...@gmail.com> Date: 2017-04-10T13:36:15Z POC for KGroupedTable.count commit 9f73f415afdeb03610440632d92386b08939cf34 Author: Eno Thereska <eno.there...@gmail.com> Date: 2017-04-10T14:01:03Z POC gor KGroupedStream.count commit fdb20ccf85ef64e5e779672ca6d4d0cb78c0f15f Author: Eno Thereska <eno.there...@gmail.com> Date: 2017-04-10T14:07:03Z Checkstyle ---- --- 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. ---