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%)
