public class TenantPartitionAssignorBuilder extends Object implements kafka.assignor.TopicReplicaAssignorBuilder
Modifier and Type | Field and Description |
---|---|
org.apache.kafka.common.Cluster |
cluster |
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)
Builds a #
TopicReplicaAssignor to be used for replica assignment. |
void |
updateClusterMetadata(org.apache.kafka.common.Cluster 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)
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 assignmentpublic void updateClusterMetadata(org.apache.kafka.common.Cluster cluster)
updateClusterMetadata
in interface kafka.assignor.TopicReplicaAssignorBuilder