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.server.multitenant.MultiTenantMetadata

Direct Known Subclasses:

CommonTopicBasedPhysicalClusterMetadata

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

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

Field Summary

Fields

Modifier and Type	Field and Description
protected static Map<String,BasePhysicalClusterMetadata>	INSTANCES

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

Methods inherited from class java.lang.Object

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

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

close, dedicatedLogicalClusterId, handleSocketServerInitialized, kafkaLogicalClusterIds, start

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

configure

Field Detail

INSTANCES

protected static final Map<String,BasePhysicalClusterMetadata> INSTANCES

Constructor Detail

BasePhysicalClusterMetadata

public BasePhysicalClusterMetadata()

Method Detail

getInstance

public static BasePhysicalClusterMetadata getInstance(String sessionUuid)

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