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 2024/05/15 07:48:41 UTC

(kafka) branch trunk updated (bf88013a281 -> d2e6c866326)

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 bf88013a281 MINOR: Rename `Record` to `CoordinatorRecord` (#15949)
     add d2e6c866326 KAFKA-10199: Remove queue-based remove from state updater (#15896)

No new revisions were added by this update.

Summary of changes:
 .../processor/internals/DefaultStateUpdater.java   |  24 +--
 .../processor/internals/PendingUpdateAction.java   |  92 ---------
 .../streams/processor/internals/StateUpdater.java  |  47 +----
 .../streams/processor/internals/TaskManager.java   |  14 +-
 .../kafka/streams/processor/internals/Tasks.java   |  99 ----------
 .../streams/processor/internals/TasksRegistry.java |  26 ---
 .../internals/DefaultStateUpdaterTest.java         |  34 ++--
 .../processor/internals/TaskManagerTest.java       |  72 ++++----
 .../streams/processor/internals/TasksTest.java     | 205 ---------------------
 9 files changed, 63 insertions(+), 550 deletions(-)
 delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/PendingUpdateAction.java