This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from ae38315 KAFKA-8855; Collect and Expose Client's Name and Version in the Brokers
(KIP-511 Part 2) (#7749)
add 8b57f6c KAFKA-6049: Add auto-repartitioning for cogroup (#7792)
No new revisions were added by this update.
Summary of changes:
docs/streams/developer-guide/dsl-api.html | 59 +-
docs/streams/upgrade-guide.html | 6 +
docs/upgrade.html | 1 +
.../internals/CogroupedStreamAggregateBuilder.java | 56 +-
.../kstream/internals/KGroupedStreamImpl.java | 9 +-
.../internals/CogroupedKStreamImplTest.java | 654 ++++++++++++++++++++-
6 files changed, 759 insertions(+), 26 deletions(-)
|