kafka git commit: MINOR: update processor topology test driver

2017-09-12 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 439050816 -> a67140317 MINOR: update processor topology test driver Author: Bill Bejeck Reviewers: Matthias J. Sax , Guozhang Wang , Damian Guy Closes

kafka git commit: MINOR: refactor build method to extract methods from if statements

2017-09-12 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk a67140317 -> e1491d4a0 MINOR: refactor build method to extract methods from if statements Author: Bill Bejeck Reviewers: Damian Guy Closes #3833 from bbejeck/MINOR_extract_methods_from_build

kafka git commit: KAFKA-4468: Correctly calculate the window end timestamp after read from state stores

2017-09-12 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 9ed8bf273 -> 90b4b07e6 KAFKA-4468: Correctly calculate the window end timestamp after read from state stores I have decided to use the following approach to fixing this bug: 1) Since the Window Size in WindowedDeserializer was originally

svn commit: r21573 - /release/kafka/KEYS

2017-09-12 Thread ijuma
Author: ijuma Date: Tue Sep 12 14:35:11 2017 New Revision: 21573 Log: Update KEYS to match the one in the kafka-site git repo Modified: release/kafka/KEYS Modified: release/kafka/KEYS == --- release/kafka/KEYS

svn commit: r21574 - /dev/kafka/KEYS

2017-09-12 Thread ijuma
Author: ijuma Date: Tue Sep 12 14:36:54 2017 New Revision: 21574 Log: Update KEYS to match the one in the kafka-site git repo Modified: dev/kafka/KEYS Modified: dev/kafka/KEYS == --- dev/kafka/KEYS (original) +++

[2/2] kafka git commit: Bump version to 0.11.0.1

2017-09-12 Thread damianguy
Bump version to 0.11.0.1 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ba8483d2 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ba8483d2 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ba8483d2 Branch:

svn commit: r21571 - in /dev/kafka: ./ 0.11.0.1/

2017-09-12 Thread damianguy
Author: damianguy Date: Tue Sep 12 13:38:14 2017 New Revision: 21571 Log: Release 0.11.0.1 Added: dev/kafka/0.11.0.1/ dev/kafka/0.11.0.1/RELEASE_NOTES.html dev/kafka/0.11.0.1/RELEASE_NOTES.html.asc dev/kafka/0.11.0.1/RELEASE_NOTES.html.md5

kafka git commit: KAFKA-5872; Fix transient failure in SslSelectorTest.testMuteOnOOM

2017-09-12 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 8bd2a68b5 -> 9ed8bf273 KAFKA-5872; Fix transient failure in SslSelectorTest.testMuteOnOOM Author: Rajini Sivaram Reviewers: Ismael Juma Closes #3836 from

svn commit: r21572 - /release/kafka/0.11.0.1/

2017-09-12 Thread ijuma
Author: ijuma Date: Tue Sep 12 14:28:13 2017 New Revision: 21572 Log: Release 0.11.0.1 Added: release/kafka/0.11.0.1/ release/kafka/0.11.0.1/RELEASE_NOTES.html release/kafka/0.11.0.1/RELEASE_NOTES.html.asc release/kafka/0.11.0.1/RELEASE_NOTES.html.md5

kafka git commit: KAFKA:5653: add join overloads to KTable

2017-09-12 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk e1491d4a0 -> 08063f50a KAFKA:5653: add join overloads to KTable Add `join`, `leftJoin`, `outerJoin` overloads that use `Materialized` to `KTable` Author: Damian Guy Reviewers: Bill Bejeck ,

kafka git commit: KAFKA-5655; materialized count, aggregate, reduce to KGroupedTable

2017-09-12 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 08063f50a -> 8bd2a68b5 KAFKA-5655; materialized count, aggregate, reduce to KGroupedTable Add overloads of `count`, `aggregate`, `reduce` using `Materialized` to `KGroupedTable` deprecate other overloads Author: Damian Guy