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 d2f900b055d MINOR: Small update docs/design.html grammar and typo
(#12691)
add d62a42df2e2 KAFKA-10199: Integrate Topology Pause/Resume with
StateUpdater (#12659)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/DefaultStateUpdater.java | 109 ++++++++-------------
.../streams/processor/internals/StateUpdater.java | 42 ++------
.../streams/processor/internals/StreamThread.java | 5 +-
.../streams/processor/internals/TaskAndAction.java | 16 +--
.../internals/DefaultStateUpdaterTest.java | 75 +++++++-------
.../processor/internals/TaskAndActionTest.java | 40 --------
.../org/apache/kafka/test/StreamsTestUtils.java | 19 ++++
7 files changed, 110 insertions(+), 196 deletions(-)
