You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by ca...@apache.org on 2022/09/16 07:05:20 UTC

[kafka] branch trunk updated (fdcde1fb78 -> a1f3c6d160)

This is an automated email from the ASF dual-hosted git repository.

cadonna pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from fdcde1fb78 MINOR: replace deprecated egrep in kafka-run-class (#12649)
     add a1f3c6d160 KAFKA-10199: Register and unregister changelog topics in state updater (#12638)

No new revisions were added by this update.

Summary of changes:
 .../streams/processor/internals/AbstractTask.java  |  5 +++
 .../processor/internals/ActiveTaskCreator.java     |  9 +++--
 .../processor/internals/ChangelogRegister.java     |  4 +++
 .../processor/internals/DefaultStateUpdater.java   | 38 ++++++++++++++--------
 .../processor/internals/ProcessorStateManager.java | 23 +++++++++----
 .../streams/processor/internals/ReadOnlyTask.java  |  5 +++
 .../processor/internals/StandbyTaskCreator.java    |  9 +++--
 .../processor/internals/StoreChangelogReader.java  | 10 ++++++
 .../streams/processor/internals/StreamThread.java  | 24 ++++++++------
 .../kafka/streams/processor/internals/Task.java    |  2 ++
 .../kafka/streams/processor/internals/Tasks.java   |  2 +-
 .../processor/internals/ActiveTaskCreatorTest.java |  4 +--
 .../internals/DefaultStateUpdaterTest.java         | 32 ++++++++++++++----
 .../processor/internals/MockChangelogReader.java   |  7 ++++
 .../internals/ProcessorStateManagerTest.java       | 15 ++++++---
 .../processor/internals/StreamThreadTest.java      |  3 +-
 .../StreamThreadStateStoreProviderTest.java        |  4 ++-
 .../org/apache/kafka/test/StreamsTestUtils.java    |  2 ++
 .../apache/kafka/streams/TopologyTestDriver.java   | 11 +++++--
 19 files changed, 154 insertions(+), 55 deletions(-)