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(-)
