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 13ffebe MINOR: Update jacoco to 0.8.7 for JDK 16 support (#10654)
add 4b27365 KAFKA-12648: MINOR - Add TopologyMetadata.Subtopology class
for subtopology metadata (#10676)
No new revisions were added by this update.
Summary of changes:
.../apache/kafka/streams/TopologyDescription.java | 10 ++--
.../org/apache/kafka/streams/processor/TaskId.java | 7 +--
.../processor/internals/ChangelogTopics.java | 18 ++++----
.../internals/InternalTopologyBuilder.java | 48 +++++++++++--------
.../processor/internals/PartitionGrouper.java | 10 ++--
.../processor/internals/RepartitionTopics.java | 9 ++--
.../internals/StreamsPartitionAssignor.java | 17 +++----
.../processor/internals/TopologyMetadata.java | 51 ++++++++++++++++++++
...opologyStreamsBuilder.java => NamedTaskId.java} | 32 ++++++-------
.../apache/kafka/streams/StreamsBuilderTest.java | 9 ++--
.../org/apache/kafka/streams/TopologyTest.java | 51 ++++++++++----------
.../kstream/internals/KStreamKStreamJoinTest.java | 6 ++-
.../streams/kstream/internals/KTableImplTest.java | 3 +-
.../processor/internals/ChangelogTopicsTest.java | 24 ++++++----
.../internals/InternalTopologyBuilderTest.java | 54 ++++++++++++----------
.../processor/internals/PartitionGrouperTest.java | 41 ++++++++--------
.../processor/internals/RepartitionTopicsTest.java | 25 +++++-----
.../internals/StreamsPartitionAssignorTest.java | 15 +++---
.../internals/assignment/AssignmentTestUtils.java | 6 +++
19 files changed, 260 insertions(+), 176 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java
copy
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/{NamedTopologyStreamsBuilder.java
=> NamedTaskId.java} (57%)
