You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ab...@apache.org on 2021/11/10 19:29:55 UTC
[kafka] branch trunk updated (39b1bf4 -> 908a6d2)
This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 39b1bf4 KAFKA-12487: Add support for cooperative consumer protocol with sink connectors (#10563)
add 908a6d2 KAFKA-12648: introduce TopologyConfig and TaskConfig for topology-level overrides (#11272)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 71 +++----
.../org/apache/kafka/streams/StreamsBuilder.java | 17 +-
.../org/apache/kafka/streams/StreamsConfig.java | 10 +-
.../java/org/apache/kafka/streams/Topology.java | 10 +-
.../kstream/internals/InternalStreamsBuilder.java | 21 +--
.../processor/internals/ActiveTaskCreator.java | 20 +-
.../internals/InternalTopologyBuilder.java | 57 +++---
.../streams/processor/internals/StandbyTask.java | 7 +-
.../processor/internals/StandbyTaskCreator.java | 12 +-
.../streams/processor/internals/StreamTask.java | 14 +-
.../streams/processor/internals/StreamThread.java | 10 +-
.../streams/processor/internals/TaskManager.java | 2 +-
.../processor/internals/TopologyMetadata.java | 6 +
.../KafkaStreamsNamedTopologyWrapper.java | 79 ++++----
.../internals/namedtopology/NamedTopology.java | 27 ++-
.../namedtopology/NamedTopologyBuilder.java} | 31 ++--
.../namedtopology/NamedTopologyStreamsBuilder.java | 51 -----
.../internals/namedtopology/TopologyConfig.java | 205 +++++++++++++++++++++
.../integration/NamedTopologyIntegrationTest.java | 129 +++++++------
.../integration/StoreQueryIntegrationTest.java | 28 +--
.../processor/internals/ActiveTaskCreatorTest.java | 4 +-
.../internals/InternalTopologyBuilderTest.java | 63 ++++++-
.../processor/internals/NamedTopologyTest.java | 113 +++++-------
.../processor/internals/StandbyTaskTest.java | 5 +-
.../processor/internals/StreamTaskTest.java | 22 ++-
.../processor/internals/StreamThreadTest.java | 62 +++++--
.../StreamThreadStateStoreProviderTest.java | 3 +-
.../apache/kafka/streams/TopologyTestDriver.java | 8 +-
28 files changed, 663 insertions(+), 424 deletions(-)
copy streams/src/main/java/org/apache/kafka/streams/{kstream/internals/graph/StateStoreNode.java => processor/internals/namedtopology/NamedTopologyBuilder.java} (51%)
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/NamedTopologyStreamsBuilder.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/TopologyConfig.java