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 c4ad09e47d7 MINOR: Add more KRaft reassignment tests (#13521)
add 750a3893081 MINOR: Follow-up on failing streams test, and fix
StoreChangelogReader (#13523)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/DefaultStateUpdater.java | 2 +-
.../streams/processor/internals/ReadOnlyTask.java | 2 +-
.../streams/processor/internals/StandbyTask.java | 6 +++-
.../streams/processor/internals/StateUpdater.java | 6 +++-
.../processor/internals/StoreChangelogReader.java | 37 ++++++++++++++++++----
.../streams/processor/internals/StreamTask.java | 14 ++++----
.../kafka/streams/processor/internals/Task.java | 2 +-
.../integration/PauseResumeIntegrationTest.java | 32 ++++++-------------
.../internals/DefaultStateUpdaterTest.java | 4 +--
.../processor/internals/StandbyTaskTest.java | 4 +--
.../internals/StoreChangelogReaderTest.java | 28 +++++++++++++---
.../processor/internals/StreamTaskTest.java | 6 ++--
.../processor/internals/TaskManagerTest.java | 2 +-
.../internals/metrics/TaskMetricsTest.java | 15 ++++++---
14 files changed, 103 insertions(+), 57 deletions(-)
