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 2023/04/12 21:57:12 UTC
[kafka] branch trunk updated (c4ad09e47d7 -> 750a3893081)
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(-)