public class AuthnzTopicBasedPhysicalClusterMetadata extends io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
backgroundUpdatesExecutorService, CLOSE_TIMEOUT_MS, lcLog, LOG, logConsumerState, logicalClusterIds, logicalClusterMap, maxPartitionRetryDelayMs, multitenantListenerNames, NUMBER_OF_TENANTS_METRIC_NAME, time, topicName
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() |
protected void |
ensureOpen() |
protected org.apache.kafka.common.metrics.Sensor |
getEndToEndSensor() |
protected String |
getSessionUuid(Map<String,?> configs) |
protected org.apache.kafka.common.metrics.Sensor |
getStartSensor() |
protected String |
getTopicClientId(Map<String,?> configs) |
protected String |
getTopicConfig() |
void |
handleSocketServerInitialized(String endpoint) |
Set<String> |
kafkaLogicalClusterIds() |
Set<String> |
logicalClusterIds() |
protected NonKafkaLogicalClusterMetadata |
parseLCM(org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record) |
protected void |
recordEndToEndSensor(NonKafkaLogicalClusterMetadata newLcm) |
protected void |
shutdown()
After this method is called, querying the cache will throw IllegalStateException
|
Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> |
start(Map<String,Object> interBrokerClientConfigs,
Collection<org.apache.kafka.common.Endpoint> endpoints) |
protected void |
startLog() |
close, configure, consume, createKafkaBasedLog, ensureNonTerminalState, isStartingOrRunningState, isUp, logicalClusterIdsIncludingStale, metadata, postUpdateBookkeeping, start, updateLogicalCluster, updateNumberOfTenantsMetric
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)
protected String getSessionUuid(Map<String,?> configs)
getSessionUuid
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
protected org.apache.kafka.common.metrics.Sensor getStartSensor()
getStartSensor
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
protected org.apache.kafka.common.metrics.Sensor getEndToEndSensor()
getEndToEndSensor
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
protected String getTopicConfig()
getTopicConfig
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
protected String getTopicClientId(Map<String,?> configs)
getTopicClientId
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
protected void shutdown()
shutdown
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
protected void ensureOpen()
ensureOpen
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
public Set<String> logicalClusterIds()
logicalClusterIds
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
public void handleSocketServerInitialized(String endpoint)
public Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> start(Map<String,Object> interBrokerClientConfigs, Collection<org.apache.kafka.common.Endpoint> endpoints)
public String dedicatedLogicalClusterId()
protected NonKafkaLogicalClusterMetadata parseLCM(org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)
parseLCM
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
protected void recordEndToEndSensor(NonKafkaLogicalClusterMetadata newLcm)
recordEndToEndSensor
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
protected void startLog()
startLog
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>