This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from c8bccdd MINOR: Fix state transition diagram for stream threads (#9153)
add 3e6dcb1 MINOR: Improve checks for CogroupedStreamAggregateBuilder
(#9141)
No new revisions were added by this update.
Summary of changes:
.../kstream/internals/CogroupedKStreamImpl.java | 5 +-
.../internals/CogroupedStreamAggregateBuilder.java | 170 +++++++++++++--------
.../SessionWindowedCogroupedKStreamImpl.java | 4 +-
.../TimeWindowedCogroupedKStreamImpl.java | 22 ++-
4 files changed, 121 insertions(+), 80 deletions(-)
