public class AuthnzTopicBasedPhysicalClusterMetadata extends io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
Constructor and Description |
---|
AuthnzTopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics) |
AuthnzTopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
String |
dedicatedLogicalClusterId() |
void |
handleSocketServerInitialized() |
Set<String> |
kafkaLogicalClusterIds() |
Set<String> |
logicalClusterIds() |
Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> |
start(Map<String,Object> interBrokerClientConfigs,
Collection<org.apache.kafka.common.Endpoint> endpoints) |
void |
updateClientConfigs(Map<String,Object> interBrokerClientConfigs) |
close, configure, consume, isUp, logicalClusterIdsIncludingStale, metadata, start
public AuthnzTopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics)
public AuthnzTopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.common.utils.Time time)
public Set<String> logicalClusterIds()
logicalClusterIds
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
public void handleSocketServerInitialized()
public Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> start(Map<String,Object> interBrokerClientConfigs, Collection<org.apache.kafka.common.Endpoint> endpoints)
public String dedicatedLogicalClusterId()