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 7a1d1d9 KAFKA-12212; Bump Metadata API version to remove
`ClusterAuthorizedOperations` fields (KIP-700) (#9945)
add 019cd4a KAFKA-10357: Extract setup of repartition topics from Streams
partition assignor (#9848)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/common/PartitionInfo.java | 2 -
.../internals/InternalTopologyBuilder.java | 2 +-
.../processor/internals/RepartitionTopics.java | 212 ++++++++++
.../internals/StreamsPartitionAssignor.java | 151 +-------
.../processor/internals/RepartitionTopicsTest.java | 429 +++++++++++++++++++++
5 files changed, 655 insertions(+), 141 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionTopicsTest.java
