You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/09/09 19:03:07 UTC
[kafka] branch trunk updated (09d1498 -> dd2b9ec)
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 09d1498 KAFKA-10436: Implement KIP-478 Topology changes (#9221)
add dd2b9ec KAFKA-5636: Improve handling of "early" records in sliding windows (#9157)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 3 +
.../internals/KStreamSlidingWindowAggregate.java | 267 ++++++++++++++++-----
.../KStreamSlidingWindowAggregateTest.java | 204 +++++++++++++++-
3 files changed, 401 insertions(+), 73 deletions(-)