public class TenantPartitionAssignorBuilder extends Object implements kafka.assignor.TopicReplicaAssignorBuilder
Constructor and Description |
---|
TenantPartitionAssignorBuilder() |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs) |
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. |
void |
updateClusterDescriber(org.apache.kafka.metadata.placement.ClusterDescriber cluster) |
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public Optional<kafka.assignor.TopicReplicaAssignor> maybeBuildAssignor(Optional<org.apache.kafka.common.security.auth.KafkaPrincipal> principalOpt, org.apache.kafka.common.PartitionPlacementStrategy targetPlacementStrategy)
TopicReplicaAssignor
to be used for replica assignment.maybeBuildAssignor
in interface kafka.assignor.TopicReplicaAssignorBuilder
principalOpt
- - the optional principal of the user which requested the topic replica assignmenttargetPlacementStrategy
- - the desired partition placementpublic void updateClusterDescriber(org.apache.kafka.metadata.placement.ClusterDescriber cluster)
updateClusterDescriber
in interface kafka.assignor.TopicReplicaAssignorBuilder