kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (7b62248 -> 0f177ea)
Date Mon, 09 Sep 2019 00:07:03 GMT
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%)


Mime
View raw message