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 0a1ef2e MINOR: Group KafkaController, ReplicaManager metrics in
documentation (#7891)
add 16b2ce7 KAFKA-12648: basic skeleton API for NamedTopology (#10615)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/StreamsBuilder.java | 16 ++-
.../java/org/apache/kafka/streams/Topology.java | 2 +-
.../org/apache/kafka/streams/processor/TaskId.java | 135 ++++++++++++++++++---
.../internals/InternalTopologyBuilder.java | 5 +
.../processor/internals/StateDirectory.java | 4 +-
.../streams/processor/internals/TaskManager.java | 2 +-
.../internals/assignment/AssignmentInfo.java | 9 +-
.../StreamsAssignmentProtocolVersions.java | 6 +-
.../KafkaStreamsNamedTopologyWrapper.java | 42 +++++++
.../internals/namedtopology/NamedTopology.java | 39 +++---
.../namedtopology/NamedTopologyStreamsBuilder.java | 39 +++---
...ghAvailabilityStreamsPartitionAssignorTest.java | 9 +-
.../internals/assignment/AssignmentTestUtils.java | 5 +
.../assignment/LegacySubscriptionInfoSerde.java | 33 ++---
.../assignment/StickyTaskAssignorTest.java | 22 ++--
.../kafka/streams/tests/StreamsUpgradeTest.java | 4 +-
16 files changed, 277 insertions(+), 95 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java
copy metadata/src/test/java/org/apache/kafka/metadata/BrokerStateTest.java =>
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/NamedTopology.java
(52%)
copy clients/src/main/java/org/apache/kafka/clients/admin/AbstractOptions.java
=>
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/NamedTopologyStreamsBuilder.java
(55%)
