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 1263576 MINOR: add process(Test)Messages to the README (#8480)
add 640be46 HOTFIX: don't close or wipe out someone else's state (#8478)
No new revisions were added by this update.
Summary of changes:
.../streams/processor/internals/StandbyTask.java | 5 +-
.../processor/internals/StateManagerUtil.java | 60 ++++++++-------
.../streams/processor/internals/StreamTask.java | 8 +-
.../streams/processor/internals/TaskManager.java | 5 --
.../processor/internals/StateManagerUtilTest.java | 85 ++++++++++++++++------
.../processor/internals/StreamTaskTest.java | 3 +
6 files changed, 98 insertions(+), 68 deletions(-)
