io.confluent.security.auth.dataplane

Class AuthnzTopicBasedPhysicalClusterMetadata

java.lang.Object

io.confluent.kafka.multitenant.BasePhysicalClusterMetadata<LCMType>

io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>

io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata

All Implemented Interfaces:

org.apache.kafka.common.Configurable, org.apache.kafka.common.Reconfigurable, org.apache.kafka.server.multitenant.MultiTenantMetadata

public class AuthnzTopicBasedPhysicalClusterMetadata
extends io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>

This holds metadata passed from CCloud related to this physical cluster

Nested Class Summary

Nested classes/interfaces inherited from class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata

io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata.State

Field Summary

Fields inherited from class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata

NUMBER_OF_NON_HC_TENANTS_METRIC_NAME, NUMBER_OF_TENANTS_METRIC_NAME

Fields inherited from interface org.apache.kafka.server.multitenant.MultiTenantMetadata

CONFLUENT_ENV_ID

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
String	dedicatedLogicalClusterId()
boolean	isUp()
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	startClients(Function<String,org.apache.kafka.clients.admin.Admin> adminClientSupplier)

Methods inherited from class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata

close, configure, consume, logicalClusterIdsIncludingStale, metadata, start

Methods inherited from class io.confluent.kafka.multitenant.BasePhysicalClusterMetadata

getInstance, reconfigurableConfigs, reconfigure, validateReconfiguration

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.kafka.server.multitenant.MultiTenantMetadata

ensureOpen, firstActiveUserLkcMetadata, registerTenantCallback, registerTenantDeactivatedCallback

Constructor Detail

AuthnzTopicBasedPhysicalClusterMetadata

public AuthnzTopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics)

AuthnzTopicBasedPhysicalClusterMetadata

public AuthnzTopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics,
                                               org.apache.kafka.common.utils.Time time)

Method Detail

isUp

public boolean isUp()

logicalClusterIds

public Set<String> logicalClusterIds()

Specified by:

logicalClusterIds in interface org.apache.kafka.server.multitenant.MultiTenantMetadata

Specified by:

logicalClusterIds in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>

startClients

public void startClients(Function<String,org.apache.kafka.clients.admin.Admin> adminClientSupplier)

start

public Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> start(Map<String,Object> interBrokerClientConfigs,
                                                                           Collection<org.apache.kafka.common.Endpoint> endpoints)

dedicatedLogicalClusterId

public String dedicatedLogicalClusterId()

kafkaLogicalClusterIds

public Set<String> kafkaLogicalClusterIds()