You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2023/02/10 07:26:12 UTC
[kafka] branch trunk updated (083e11a22ca -> 39962eeeb3c)

This is an automated email from the ASF dual-hosted git repository.

dajac pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from 083e11a22ca KAFKA-14650: Synchronize access to tasks inside task manager (#13167)
     add 39962eeeb3c KAFKA-14513; Add broker side PartitionAssignor interface (#13202)

No new revisions were added by this update.

Summary of changes:
 checkstyle/import-control.xml                      |  1 +
 .../group/assignor/AssignmentMemberSpec.java       | 95 ++++++++++++++++++++++
 .../coordinator/group/assignor/AssignmentSpec.java | 56 +++++++------
 .../group/assignor/AssignmentTopicMetadata.java    | 58 ++++++-------
 .../group/assignor/GroupAssignment.java            | 32 +++++---
 .../group/assignor/MemberAssignment.java           | 45 +++++-----
 .../group/assignor/PartitionAssignor.java          | 27 ++++--
 .../group/assignor/PartitionAssignorException.java | 17 ++--
 8 files changed, 225 insertions(+), 106 deletions(-)
 create mode 100644 group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AssignmentMemberSpec.java
 copy clients/src/main/java/org/apache/kafka/common/ClusterResource.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AssignmentSpec.java (52%)
 copy trogdor/src/main/java/org/apache/kafka/trogdor/rest/ErrorResponse.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AssignmentTopicMetadata.java (55%)
 copy trogdor/src/main/java/org/apache/kafka/trogdor/rest/Empty.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/GroupAssignment.java (62%)
 copy server-common/src/main/java/org/apache/kafka/server/common/ApiMessageAndVersion.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/MemberAssignment.java (58%)
 copy metadata/src/main/java/org/apache/kafka/metadata/placement/ClusterDescriber.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/PartitionAssignor.java (59%)
 copy clients/src/main/java/org/apache/kafka/common/InvalidRecordException.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/PartitionAssignorException.java (69%)