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(-)