You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by lu...@apache.org on 2025/01/02 15:31:42 UTC
(kafka) branch trunk updated (0344f8f5ae4 -> dd0fd553163)

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

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


    from 0344f8f5ae4 KAFKA-18273: KIP-1099 verbose display share group options (#18259)
     add dd0fd553163 KAFKA-18319: Add task assignor interfaces (#18270)

No new revisions were added by this update.

Summary of changes:
 .../streams/assignor/AssignmentMemberSpec.java     |  60 +++++
 .../group/streams/assignor/GroupAssignment.java    |  17 +-
 .../group/streams/assignor/GroupSpec.java          |  18 +-
 .../group/streams/assignor/GroupSpecImpl.java      |  19 +-
 .../group/streams/assignor/MemberAssignment.java   |  30 +--
 .../group/streams/assignor/MockAssignor.java       | 106 ++++++++
 .../group/streams/assignor/TaskAssignor.java}      |  18 +-
 .../streams/assignor/TaskAssignorException.java}   |  11 +-
 .../coordinator/group/streams/assignor/TaskId.java |  29 ++-
 .../group/streams/assignor/TopologyDescriber.java  |  50 ++++
 .../group/streams/assignor/GroupSpecImplTest.java  |  56 ++---
 .../group/streams/assignor/MockAssignorTest.java   | 267 +++++++++++++++++++++
 12 files changed, 590 insertions(+), 91 deletions(-)
 create mode 100644 group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/AssignmentMemberSpec.java
 copy clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsOptions.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupAssignment.java (70%)
 copy metadata/src/main/java/org/apache/kafka/metadata/LeaderConstants.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpec.java (71%)
 copy connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SimpleConfig.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImpl.java (59%)
 copy trogdor/src/main/java/org/apache/kafka/trogdor/rest/TasksResponse.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MemberAssignment.java (52%)
 create mode 100644 group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MockAssignor.java
 copy group-coordinator/{group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/PartitionAssignor.java => src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TaskAssignor.java} (65%)
 copy group-coordinator/{group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/PartitionAssignorException.java => src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TaskAssignorException.java} (70%)
 copy clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/TopicMetadataEvent.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TaskId.java (57%)
 create mode 100644 group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TopologyDescriber.java
 copy connect/transforms/src/test/java/org/apache/kafka/connect/transforms/TimestampRouterTest.java => group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImplTest.java (52%)
 create mode 100644 group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/MockAssignorTest.java