You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2022/09/28 23:26:10 UTC
[kafka] branch trunk updated (d2f900b055d -> d62a42df2e2)
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(-)