You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by sh...@apache.org on 2022/03/17 02:21:57 UTC
[kafka] branch trunk updated (b68463c -> fbe7fb9)

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

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


    from b68463c  KAFKA-6718 / Add rack awareness configurations to StreamsConfig (#11837)
     add fbe7fb9  KAFKA-9847: add config to set default store type (KIP-591) (#11705)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/StreamsBuilder.java   |  10 +-
 .../org/apache/kafka/streams/StreamsConfig.java    |  14 +
 .../java/org/apache/kafka/streams/Topology.java    |   4 +
 .../namedtopology => }/TopologyConfig.java         |  89 ++-
 .../apache/kafka/streams/kstream/Materialized.java |  46 +-
 .../kstream/internals/MaterializedInternal.java    |  17 +
 .../SessionWindowedCogroupedKStreamImpl.java       |  22 +-
 .../internals/SessionWindowedKStreamImpl.java      |  22 +-
 .../SlidingWindowedCogroupedKStreamImpl.java       |  29 +-
 .../internals/SlidingWindowedKStreamImpl.java      |  29 +-
 .../TimeWindowedCogroupedKStreamImpl.java          |  26 +-
 .../kstream/internals/TimeWindowedKStreamImpl.java |  28 +-
 .../TimestampedKeyValueStoreMaterializer.java      |  13 +-
 .../internals/InternalTopologyBuilder.java         |   2 +-
 .../streams/processor/internals/StandbyTask.java   |   2 +-
 .../streams/processor/internals/StreamTask.java    |   2 +-
 .../processor/internals/TopologyMetadata.java      |   2 +-
 .../internals/namedtopology/NamedTopology.java     |   1 +
 .../namedtopology/NamedTopologyBuilder.java        |   1 +
 .../apache/kafka/streams/StreamsConfigTest.java    |  25 +-
 .../org/apache/kafka/streams/TopologyTest.java     | 677 ++++++++++++++++++++-
 .../kafka/streams/kstream/MaterializedTest.java    |  17 +
 .../kstream/internals/KGroupedStreamImplTest.java  |   2 +-
 .../internals/MaterializedInternalTest.java        |  22 +
 .../processor/internals/ActiveTaskCreatorTest.java |   2 +-
 .../internals/InternalTopologyBuilderTest.java     |   5 +-
 .../processor/internals/StandbyTaskTest.java       |   2 +-
 .../processor/internals/StreamTaskTest.java        |   2 +-
 .../StreamThreadStateStoreProviderTest.java        |   2 +-
 .../apache/kafka/streams/TopologyTestDriver.java   |   2 +-
 30 files changed, 1009 insertions(+), 108 deletions(-)
 rename streams/src/main/java/org/apache/kafka/streams/{processor/internals/namedtopology => }/TopologyConfig.java (78%)