kafka git commit: MINOR: KIP-160 docs

2017-08-30 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk f5310d645 -> ce04b1435 MINOR: KIP-160 docs Author: Guozhang Wang Reviewers: Damian Guy Closes #3733 from guozhangwang/KMinor-kip160-docs Project:

kafka git commit: MINOR: doc changes for KIP-138

2017-08-30 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 6682abe4a -> f5310d645 MINOR: doc changes for KIP-138 1. Core concepts (added the stream time definition), upgrade guide and developer guide. 2. Related Java docs changes. Author: Guozhang Wang Reviewers: Bill Bejeck

kafka-site git commit: Jason and Becket are PMC members

2017-08-30 Thread jgus
Repository: kafka-site Updated Branches: refs/heads/asf-site f18b90462 -> 52b928144 Jason and Becket are PMC members Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/52b92814 Tree:

kafka git commit: KAFKA-5797: Delay checking of partition existence in StoreChangelogReader

2017-08-30 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 76c9a6dcb -> 6682abe4a KAFKA-5797: Delay checking of partition existence in StoreChangelogReader 1. Remove timeout-based validatePartitionExists from StoreChangelogReader; instead only try to refresh metadata once after all tasks have been

kafka git commit: KAFKA-5804; retain duplicates in ChangeLoggingWindowBytesStore

2017-08-30 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 10cb534c8 -> 76c9a6dcb KAFKA-5804; retain duplicates in ChangeLoggingWindowBytesStore `ChangeLoggingWindowBytesStore` needs to have the same `retainDuplicates` functionality as `RocksDBWindowStore` else data could be lost upon

kafka git commit: KAFKA-5762; Refactor AdminClient to use LogContext

2017-08-30 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk bd54d2e3e -> 10cb534c8 KAFKA-5762; Refactor AdminClient to use LogContext - client id is part of the log context, so removed ad-hoc usages - Fixed an issue where the response was not printed correctly, use `toString(version)` instead of

kafka git commit: MINOR: stateful docs for aggregates

2017-08-30 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 949577ca7 -> bd54d2e3e MINOR: stateful docs for aggregates Author: Eno Thereska Reviewers: Damian Guy Closes #3730 from enothereska/minor-docs-aggregates Project: