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:
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
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:
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
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
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
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: