Package io.confluent.kafka.multitenant

Class BasePhysicalClusterMetadata<LCMType extends org.apache.kafka.server.multitenant.LogicalClusterMetadata>

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

CommonTopicBasedPhysicalClusterMetadata

public abstract class BasePhysicalClusterMetadata<LCMType extends org.apache.kafka.server.multitenant.LogicalClusterMetadata>
extends Object
implements org.apache.kafka.server.multitenant.MultiTenantMetadata, org.apache.kafka.common.Reconfigurable

Base class for the PhysicalClusterMetadata plugins, interfacing with other confluent plugins

Field Summary

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

CONFLUENT_ENV_ID

Constructor Summary

Constructors

Constructor	Description
BasePhysicalClusterMetadata()

Method Summary

Modifier and Type	Method	Description
static BasePhysicalClusterMetadata	getInstance(String sessionUuid)
abstract Set<String>	logicalClusterIdsIncludingStale()	Returns all active logical clusters hosted by this physical cluster, including logical clusters with stale/invalid metadata
abstract LCMType	metadata(String logicalClusterId)	Returns metadata LCMType of a given logical cluster ID
Set<String>	reconfigurableConfigs()
void	reconfigure(Map<String,?> configs)
void	validateReconfiguration(Map<String,?> configs)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.Configurable

configure

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

close, dedicatedLogicalClusterId, ensureOpen, firstActiveUserLkcMetadata, isUp, kafkaLogicalClusterIds, logicalClusterIds, registerTenantCallback, registerTenantDeactivatedCallback, registerTenantMetadataUpdateCallback, start, startClients

Constructor Details

BasePhysicalClusterMetadata

public BasePhysicalClusterMetadata()

Method Details

getInstance

public static BasePhysicalClusterMetadata getInstance(String sessionUuid)

reconfigure

public void reconfigure(Map<String,?> configs)

Specified by:

reconfigure in interface org.apache.kafka.common.Reconfigurable

reconfigurableConfigs

public Set<String> reconfigurableConfigs()

Specified by:

reconfigurableConfigs in interface org.apache.kafka.common.Reconfigurable

validateReconfiguration

public void validateReconfiguration(Map<String,?> configs)
                             throws org.apache.kafka.common.config.ConfigException

Specified by:

validateReconfiguration in interface org.apache.kafka.common.Reconfigurable

Throws:

org.apache.kafka.common.config.ConfigException

logicalClusterIdsIncludingStale

public abstract Set<String> logicalClusterIdsIncludingStale()

Returns all active logical clusters hosted by this physical cluster, including logical clusters with stale/invalid metadata

Returns:

set of logical cluster IDs

Throws:

IllegalStateException - if not yet started or already shut down

metadata

public abstract LCMType metadata(String logicalClusterId)

Returns metadata LCMType of a given logical cluster ID

Specified by:

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

Parameters:

logicalClusterId - logical cluster ID

Returns:

logical cluster metadata LCMType or null if logical cluster does not exist or its metadata is stale

Throws:

IllegalStateException - if not yet started or already shut down