This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 9dc332f5ca KAFKA-13217: Reconsider skipping the LeaveGroup on close()
or add an overload that does so (#12035)
add 286bae4251 KAFKA-10199: Implement adding standby tasks to the state
updater (#12200)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/ChangelogReader.java | 9 +
.../processor/internals/DefaultStateUpdater.java | 125 +++++++++---
.../streams/processor/internals/StateUpdater.java | 12 +-
.../internals/DefaultStateUpdaterTest.java | 226 ++++++++++++++++-----
4 files changed, 290 insertions(+), 82 deletions(-)
