This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 7b62248 MINOR: Add cause to thrown exception when deleting topic in
TopicCommand (#7301)
add 0f177ea MINOR: Clean up partition assignment logic (#7249)
No new revisions were added by this update.
Summary of changes:
.../streams/internals/QuietStreamsConfig.java | 0
.../processor/internals/InternalTopicConfig.java | 10 +-
.../processor/internals/InternalTopicManager.java | 13 +-
.../streams/processor/internals/StreamThread.java | 9 +-
.../internals/StreamsPartitionAssignor.java | 548 ++++++++-------------
.../streams/processor/internals/TaskManager.java | 6 +-
.../internals/assignment/AssignmentInfo.java | 7 +-
.../assignment/AssignorConfiguration.java | 188 +++++++
.../{TaskAssignor.java => AssignorError.java} | 17 +-
.../assignment/CopartitionedTopicsEnforcer.java | 110 +++++
...java => StreamsAssignmentProtocolVersions.java} | 13 +-
.../internals/assignment/SubscriptionInfo.java | 7 +-
...t.java => CopartitionedTopicsEnforcerTest.java} | 43 +-
.../internals/StreamsPartitionAssignorTest.java | 174 ++++---
.../internals/assignment/AssignmentInfoTest.java | 16 +-
.../internals/assignment/SubscriptionInfoTest.java | 22 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 35 +-
.../kafka/test/MockInternalTopicManager.java | 2 +-
18 files changed, 711 insertions(+), 509 deletions(-)
rename streams/{test-utils =>
}/src/main/java/org/apache/kafka/streams/internals/QuietStreamsConfig.java
(100%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java
copy
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/{TaskAssignor.java
=> AssignorError.java} (77%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/CopartitionedTopicsEnforcer.java
copy
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/{TaskAssignor.java
=> StreamsAssignmentProtocolVersions.java} (62%)
rename
streams/src/test/java/org/apache/kafka/streams/processor/internals/{CopartitionedTopicsValidatorTest.java
=> CopartitionedTopicsEnforcerTest.java} (73%)
