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 fd36e5a KAFKA-12851: Fix Raft partition simulation (#11134)
add 4710a49 KAFKA-12648: Pt. 2 - Introduce TopologyMetadata to wrap
InternalTopologyBuilders of named topologies (#10683)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../org/apache/kafka/streams/KafkaStreams.java | 92 +++---
.../org/apache/kafka/streams/processor/TaskId.java | 30 +-
.../processor/internals/ActiveTaskCreator.java | 10 +-
.../internals/InternalTopologyBuilder.java | 196 ++++++++-----
.../processor/internals/ProcessorContextUtils.java | 4 +-
.../processor/internals/ProcessorStateManager.java | 8 +-
.../processor/internals/ProcessorTopology.java | 7 -
.../processor/internals/RepartitionTopics.java | 10 +-
.../processor/internals/StandbyTaskCreator.java | 19 +-
.../processor/internals/StateDirectory.java | 28 +-
.../streams/processor/internals/StreamThread.java | 54 ++--
.../processor/internals/StreamsMetadataState.java | 18 +-
.../internals/StreamsPartitionAssignor.java | 5 +-
.../streams/processor/internals/TaskManager.java | 16 +-
.../kafka/streams/processor/internals/Tasks.java | 8 +-
.../processor/internals/TopologyMetadata.java | 296 +++++++++++++++++++-
.../KafkaStreamsNamedTopologyWrapper.java | 79 +++++-
.../internals/namedtopology/NamedTopology.java | 7 +
.../namedtopology/NamedTopologyStreamsBuilder.java | 9 +-
.../state/internals/CachingWindowStore.java | 2 +-
.../InMemoryTimeOrderedKeyValueBuffer.java | 2 +-
.../state/internals/MeteredKeyValueStore.java | 39 ++-
.../state/internals/MeteredSessionStore.java | 37 +--
.../state/internals/MeteredWindowStore.java | 27 +-
.../org/apache/kafka/streams/KafkaStreamsTest.java | 9 +-
.../integration/InternalTopicIntegrationTest.java | 4 +-
.../integration/NamedTopologyIntegrationTest.java | 247 +++++++++++++++-
.../integration/RestoreIntegrationTest.java | 4 +-
.../integration/StandbyTaskEOSIntegrationTest.java | 2 +-
.../integration/utils/IntegrationTestUtils.java | 13 +-
.../internals/InternalStreamsBuilderTest.java | 28 +-
.../internals/AbstractProcessorContextTest.java | 2 +-
.../processor/internals/ActiveTaskCreatorTest.java | 5 +-
.../internals/GlobalStateManagerImplTest.java | 2 +-
.../internals/GlobalStreamThreadTest.java | 4 +-
...ghAvailabilityStreamsPartitionAssignorTest.java | 6 +-
.../internals/InternalTopologyBuilderTest.java | 44 +--
.../processor/internals/NamedTopologyTest.java | 311 +++++++++++++++++++++
.../internals/ProcessorStateManagerTest.java | 24 +-
.../processor/internals/RepartitionTopicsTest.java | 25 +-
.../processor/internals/StandbyTaskTest.java | 8 +-
.../processor/internals/StateDirectoryTest.java | 8 +-
.../processor/internals/StreamTaskTest.java | 2 +-
.../processor/internals/StreamThreadTest.java | 58 ++--
.../internals/StreamsAssignmentScaleTest.java | 13 +-
.../internals/StreamsMetadataStateTest.java | 19 +-
.../internals/StreamsPartitionAssignorTest.java | 26 +-
.../processor/internals/TaskManagerTest.java | 7 +-
.../DummyStreamsConfig.java} | 22 +-
.../CompositeReadOnlyKeyValueStoreTest.java | 2 +-
.../state/internals/MeteredKeyValueStoreTest.java | 4 +-
.../state/internals/MeteredSessionStoreTest.java | 4 +-
.../MeteredTimestampedKeyValueStoreTest.java | 4 +-
.../MeteredTimestampedWindowStoreTest.java | 7 +-
.../state/internals/MeteredWindowStoreTest.java | 2 +-
.../kafka/test/InternalMockProcessorContext.java | 14 +-
.../apache/kafka/test/NoOpProcessorContext.java | 2 +-
.../apache/kafka/streams/TopologyTestDriver.java | 7 +-
59 files changed, 1498 insertions(+), 446 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java
copy
streams/src/test/java/org/apache/kafka/streams/processor/internals/{MockStreamsMetrics.java
=> testutil/DummyStreamsConfig.java} (61%)
