Class TenantPartitionAssignorBuilder

java.lang.Object
io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder
All Implemented Interfaces:
kafka.assignor.TopicReplicaAssignorBuilder, org.apache.kafka.common.Configurable
public class TenantPartitionAssignorBuilder extends Object implements kafka.assignor.TopicReplicaAssignorBuilder

  • Constructor Details

    • TenantPartitionAssignorBuilder

      public TenantPartitionAssignorBuilder()

  • Method Details

    • configure

      public void configure(Map<String,?> configs)
      Specified by:
      configure in interface org.apache.kafka.common.Configurable

    • maybeBuildAssignor

      public Optional<kafka.assignor.TopicReplicaAssignor> maybeBuildAssignor(Optional<org.apache.kafka.common.security.auth.KafkaPrincipal> principalOpt, org.apache.kafka.common.PartitionPlacementStrategy targetPlacementStrategy)
      Builds a #TopicReplicaAssignor to be used for replica assignment.
      Specified by:
      maybeBuildAssignor in interface kafka.assignor.TopicReplicaAssignorBuilder
      Parameters:
      principalOpt - - the optional principal of the user which requested the topic replica assignment
      targetPlacementStrategy - - the desired partition placement

    • updateClusterDescriber

      public void updateClusterDescriber(org.apache.kafka.metadata.placement.ClusterDescriber cluster)
      Specified by:
      updateClusterDescriber in interface kafka.assignor.TopicReplicaAssignorBuilder