public class TopicBasedPhysicalClusterMetadata extends io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<KafkaLogicalClusterMetadata>
Modifier and Type | Field and Description |
---|---|
SslCertificateManager |
sslCertificateManager |
TenantLifecycleManager |
tenantLifecycleManager |
Constructor and Description |
---|
TopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics) |
TopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs)
Creates a consumer for the LKC metadata topic (named in the ConfluentConfigs.CDC_LKC_METADATA_TOPIC_CONFIG
config.)
Adds the instance for the given broker session UUID, specified in KafkaConfig.BrokerSessionUuidProp to the
static instance map.
|
String |
dedicatedLogicalClusterId() |
void |
handleSocketServerInitialized() |
Set<String> |
kafkaLogicalClusterIds() |
Set<String> |
logicalClusterIds() |
Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> |
start(Map<String,Object> interBrokerClientConfig,
Collection<org.apache.kafka.common.Endpoint> endpoints) |
public TenantLifecycleManager tenantLifecycleManager
public SslCertificateManager sslCertificateManager
public TopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics)
public TopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.common.utils.Time time)
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
configure
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<KafkaLogicalClusterMetadata>
configs
- broker configurationorg.apache.kafka.common.config.ConfigException
- if KafkaConfig.BrokerSessionUuidProp is not set, or
ConfluentConfigs.CDC_LKC_METADATA_TOPIC_CONFIG is not set, or
ConfluentConfigs.CDC_TOPIC_LOAD_TIMEOUT_MS_CONFIG is not set, or
unable to monitor the SSL certificates on disk.UnsupportedOperationException
- if another instance of this class with the same broker
session UUID was already configured.public void handleSocketServerInitialized()
public Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> start(Map<String,Object> interBrokerClientConfig, Collection<org.apache.kafka.common.Endpoint> endpoints)
public String dedicatedLogicalClusterId()
public Set<String> logicalClusterIds()
logicalClusterIds
in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<KafkaLogicalClusterMetadata>