io.confluent.kafka.multitenant

Class BasePhysicalClusterMetadata<LCMType extends 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 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

Constructor Summary

Constructors

Constructor and Description
BasePhysicalClusterMetadata()

Method Summary

Modifier and Type	Method and Description
static BasePhysicalClusterMetadata	getInstance(String sessionUuid)
abstract Set<String>	logicalClusterIds() Returns all active logical clusters with up-to-date/valid metadata hosted by this physical cluster
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.server.multitenant.MultiTenantMetadata

close, dedicatedLogicalClusterId, handleSocketServerInitialized, kafkaLogicalClusterIds, start, updateClientConfigs

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

configure

Constructor Detail

BasePhysicalClusterMetadata

public BasePhysicalClusterMetadata()

Method Detail

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

logicalClusterIds

public abstract Set<String> logicalClusterIds()

Returns all active logical clusters with up-to-date/valid metadata hosted by this physical cluster

Returns:

set of logical cluster IDs

Throws:

IllegalStateException - if not yet started or already shut down

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

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