Package org.apache.kafka.coordinator.group.api.assignor

Interface PartitionAssignor

All Known Subinterfaces:
ConsumerGroupPartitionAssignor, ShareGroupPartitionAssignor
public interface PartitionAssignor
Server-side partition assignor used by the GroupCoordinator.

  • Method Summary

    Modifier and Type
    Method
    Description
    GroupAssignment
    assign(GroupSpec groupSpec, SubscribedTopicDescriber subscribedTopicDescriber)
    Assigns partitions to group members based on the given assignment specification and topic metadata.
    String
    name()
    Unique name for this assignor.

  • Method Details