public abstract class BasePhysicalClusterMetadata extends Object implements org.apache.kafka.server.multitenant.MultiTenantMetadata
Modifier and Type | Field and Description |
---|---|
protected static Map<String,BasePhysicalClusterMetadata> |
INSTANCES |
Constructor and Description |
---|
BasePhysicalClusterMetadata() |
Modifier and Type | Method and Description |
---|---|
static BasePhysicalClusterMetadata |
getInstance(String brokerSessionUuid) |
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 LogicalClusterMetadata |
metadata(String logicalClusterId)
Returns metadata of a given logical cluster ID
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
protected static final Map<String,BasePhysicalClusterMetadata> INSTANCES
public static BasePhysicalClusterMetadata getInstance(String brokerSessionUuid)
public abstract Set<String> logicalClusterIds()
IllegalStateException
- if not yet started or already shut downpublic abstract Set<String> logicalClusterIdsIncludingStale()
IllegalStateException
- if not yet started or already shut downpublic abstract LogicalClusterMetadata metadata(String logicalClusterId)
logicalClusterId
- logical cluster IDIllegalStateException
- if not yet started or already shut down