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

Posted to commits@kafka.apache.org by mj...@apache.org on 2026/03/08 00:04:38 UTC

(kafka) branch trunk updated (03e6aa43988 -> 66cc6b6297e)

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

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


    from 03e6aa43988 KAFKA-20266: Add tracking of assignment timestamps (#21652)
     add 66cc6b6297e KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors (#21535)

No new revisions were added by this update.

Summary of changes:
 docs/streams/developer-guide/config-streams.md     |  29 +++-
 docs/streams/upgrade-guide.md                      |   2 +
 .../integration/GlobalKTableIntegrationTest.java   | 150 ++++++++++++++++++++-
 .../org/apache/kafka/streams/StreamsConfig.java    |  15 +++
 .../internals/GlobalStateManagerImpl.java          | 118 +++++++++++++---
 .../processor/internals/GlobalStateUpdateTask.java |   6 +-
 .../processor/internals/GlobalStreamThread.java    |   5 +-
 .../internals/InternalTopologyBuilder.java         |  11 +-
 .../streams/processor/internals/ProcessorNode.java |  34 ++---
 .../internals/GlobalStateManagerImplTest.java      |   1 +
 .../processor/internals/GlobalStateTaskTest.java   | 121 +++++++++++++++++
 .../apache/kafka/streams/TopologyTestDriver.java   |   7 +
 12 files changed, 457 insertions(+), 42 deletions(-)