This is an automated email from the ASF dual-hosted git repository. vvcephei pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 8e9cf0e MINOR: mirror integration tests should not call System.exit (#9200) add 09d1498 KAFKA-10436: Implement KIP-478 Topology changes (#9221) No new revisions were added by this update. Summary of changes: .../examples/docs/DeveloperGuideTesting.java | 21 ++- .../java/org/apache/kafka/streams/Topology.java | 142 ++++++++++++++-- .../apache/kafka/streams/TopologyDescription.java | 5 +- .../kstream/internals/InternalStreamsBuilder.java | 4 +- .../streams/kstream/internals/KStreamImpl.java | 30 ++-- .../streams/kstream/internals/KStreamImplJoin.java | 10 +- .../streams/kstream/internals/KTableImpl.java | 20 +-- .../internals/graph/BaseJoinProcessorNode.java | 18 +-- .../internals/graph/BaseRepartitionNode.java | 8 +- .../internals/graph/GraphGraceSearchUtil.java | 2 +- .../GroupedTableOperationRepartitionNode.java | 2 +- .../internals/graph/KTableKTableJoinNode.java | 33 ++-- .../graph/OptimizableRepartitionNode.java | 2 +- .../internals/graph/ProcessorGraphNode.java | 8 +- .../internals/graph/ProcessorParameters.java | 49 +++++- .../internals/graph/StatefulProcessorNode.java | 19 ++- .../internals/graph/StreamStreamJoinNode.java | 34 ++-- .../internals/graph/StreamTableJoinNode.java | 8 +- .../kstream/internals/graph/StreamToTableNode.java | 6 +- .../internals/graph/TableProcessorNode.java | 11 +- .../kstream/internals/graph/TableSourceNode.java | 14 +- .../graph/UnoptimizableRepartitionNode.java | 2 +- .../streams/processor/ConnectedStoreProvider.java | 2 +- .../kafka/streams/processor/ProcessorContext.java | 3 +- .../streams/processor/api/ProcessorContext.java | 3 +- .../internals/InternalTopologyBuilder.java | 6 +- .../processor/internals/ProcessorAdapter.java | 9 ++ .../internals/ProcessorContextAdapter.java | 5 +- .../org/apache/kafka/streams/KafkaStreamsTest.java | 30 +++- .../apache/kafka/streams/StreamsBuilderTest.java | 2 +- .../org/apache/kafka/streams/TopologyTest.java | 37 ++--- .../integration/RegexSourceIntegrationTest.java | 6 +- .../kstream/internals/KTableFilterTest.java | 16 +- .../internals/KTableKTableInnerJoinTest.java | 16 +- .../internals/KTableKTableLeftJoinTest.java | 14 +- .../internals/KTableKTableOuterJoinTest.java | 14 +- .../kstream/internals/KTableMapValuesTest.java | 13 +- .../kstream/internals/KTableSourceTest.java | 14 +- ...ghAvailabilityStreamsPartitionAssignorTest.java | 6 +- .../internals/InternalTopologyBuilderTest.java | 65 ++++---- .../processor/internals/ProcessorTopologyTest.java | 180 ++++++++++++++++----- .../processor/internals/StreamThreadTest.java | 77 ++++----- .../internals/StreamsPartitionAssignorTest.java | 98 +++++------ .../StreamThreadStateStoreProviderTest.java | 4 +- .../kafka/streams/TopologyTestDriverTest.java | 118 +++++++------- 45 files changed, 742 insertions(+), 444 deletions(-)