public abstract class BasePhysicalClusterMetadata<LCMType extends LogicalClusterMetadata> extends Object implements org.apache.kafka.server.multitenant.MultiTenantMetadata, org.apache.kafka.common.Reconfigurable
Constructor and Description |
---|
BasePhysicalClusterMetadata() |
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) |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public static BasePhysicalClusterMetadata getInstance(String sessionUuid)
public void reconfigure(Map<String,?> configs)
reconfigure
in interface org.apache.kafka.common.Reconfigurable
public Set<String> reconfigurableConfigs()
reconfigurableConfigs
in interface org.apache.kafka.common.Reconfigurable
public void validateReconfiguration(Map<String,?> configs) throws org.apache.kafka.common.config.ConfigException
validateReconfiguration
in interface org.apache.kafka.common.Reconfigurable
org.apache.kafka.common.config.ConfigException
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 LCMType metadata(String logicalClusterId)
logicalClusterId
- logical cluster IDIllegalStateException
- if not yet started or already shut down