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

Posted to commits@kafka.apache.org by wc...@apache.org on 2024/03/28 15:30:25 UTC

(kafka) branch trunk updated (355873aa544 -> 8b274d8c1bf)

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

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


    from 355873aa544 MINOR: Use CONFIG suffix in ZkConfigs (#15614)
     add 8b274d8c1bf KAFKA-7663: Reprocessing on user added global stores restore (#15414)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/StreamsBuilder.java   |  13 +-
 .../java/org/apache/kafka/streams/Topology.java    |  12 +-
 .../kstream/internals/InternalStreamsBuilder.java  |   7 +-
 .../kstream/internals/graph/GlobalStoreNode.java   |   9 +-
 .../kstream/internals/graph/TableSourceNode.java   |   3 +-
 .../internals/GlobalStateManagerImpl.java          | 123 +++++++++++++++++--
 .../internals/InternalTopologyBuilder.java         |  39 +++++-
 .../processor/internals/ProcessorTopology.java     |  10 +-
 .../processor/internals/RecordDeserializer.java    |  71 ++++++-----
 .../state/internals/InMemoryKeyValueStore.java     |   2 +
 ...rderTest.java => GlobalStateReprocessTest.java} | 131 ++++++++-------------
 .../integration/GlobalThreadShutDownOrderTest.java |  18 ++-
 .../internals/GlobalStateManagerImplTest.java      |  85 +++++++++++--
 .../internals/GlobalStreamThreadTest.java          |   4 +-
 .../internals/InternalTopologyBuilderTest.java     |  31 +++--
 .../internals/ProcessorTopologyFactories.java      |   7 +-
 .../processor/internals/RecordCollectorTest.java   |  21 ++--
 .../processor/internals/StreamTaskTest.java        |   6 +-
 18 files changed, 420 insertions(+), 172 deletions(-)
 copy streams/src/test/java/org/apache/kafka/streams/integration/{GlobalThreadShutDownOrderTest.java => GlobalStateReprocessTest.java} (64%)