You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/04/09 23:53:11 UTC
[kafka] branch trunk updated (0470e2b -> e131a99)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 0470e2b KAFKA-6145: KIP-441: fix flaky shouldEnforceRebalance test in StreamThreadTest (#8452)
add e131a99 KAFKA-8611: Add KStream#repartition operation (#7170)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/kstream/KStream.java | 47 +-
.../kafka/streams/kstream/Repartitioned.java | 171 +++++
.../internals/CogroupedStreamAggregateBuilder.java | 1 +
.../internals/GroupedStreamAggregateBuilder.java | 1 +
.../kstream/internals/InternalStreamsBuilder.java | 1 +
.../streams/kstream/internals/KStreamImpl.java | 95 ++-
.../streams/kstream/internals/KTableImpl.java | 5 +-
...cedInternal.java => RepartitionedInternal.java} | 28 +-
.../internals/graph/BaseRepartitionNode.java | 82 +-
.../GroupedTableOperationRepartitionNode.java | 75 +-
.../KTableKTableForeignKeyJoinResolutionNode.java | 3 +-
.../graph/OptimizableRepartitionNode.java | 103 +--
.../graph/UnoptimizableRepartitionNode.java | 105 +++
.../processor/internals/InternalTopicConfig.java | 39 +-
...Extractor.java => InternalTopicProperties.java} | 25 +-
.../internals/InternalTopologyBuilder.java | 44 +-
.../internals/RepartitionTopicConfig.java | 13 +-
.../internals/StreamsPartitionAssignor.java | 5 +-
.../internals/UnwindowedChangelogTopicConfig.java | 6 +-
.../internals/WindowedChangelogTopicConfig.java | 8 +-
.../assignment/CopartitionedTopicsEnforcer.java | 84 ++-
.../KStreamRepartitionIntegrationTest.java | 826 +++++++++++++++++++++
.../kstream/internals/KStreamRepartitionTest.java | 110 +++
.../kstream/internals/graph/StreamsGraphTest.java | 35 +
.../internals/CopartitionedTopicsEnforcerTest.java | 96 ++-
.../internals/InternalTopicConfigTest.java | 5 +
.../internals/InternalTopologyBuilderTest.java | 74 +-
.../processor/internals/ProcessorTopologyTest.java | 4 +-
.../internals/RepartitionTopicConfigTest.java | 58 ++
.../internals/StreamsPartitionAssignorTest.java | 14 +-
30 files changed, 1922 insertions(+), 241 deletions(-)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/Repartitioned.java
copy streams/src/main/java/org/apache/kafka/streams/kstream/internals/{ProducedInternal.java => RepartitionedInternal.java} (62%)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java
copy streams/src/main/java/org/apache/kafka/streams/processor/internals/{StaticTopicNameExtractor.java => InternalTopicProperties.java} (61%)
create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/KStreamRepartitionIntegrationTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamRepartitionTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfigTest.java