io.confluent.kafka.multitenant

Class TopicBasedPhysicalClusterMetadata

java.lang.Object

io.confluent.kafka.multitenant.BasePhysicalClusterMetadata<LCMType>

io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<KafkaLogicalClusterMetadata>

io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

All Implemented Interfaces:

org.apache.kafka.common.Configurable, org.apache.kafka.server.multitenant.MultiTenantMetadata

public class TopicBasedPhysicalClusterMetadata
extends io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<KafkaLogicalClusterMetadata>

This holds metadata passed from CCloud related to this physical cluster

Nested Class Summary

Nested classes/interfaces inherited from class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata

io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata.State

Field Summary

Fields

Modifier and Type	Field and Description
SslCertificateManager	sslCertificateManager
TenantLifecycleManager	tenantLifecycleManager

Fields inherited from class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata

NUMBER_OF_TENANTS_METRIC_NAME

Constructor Summary

Constructors

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)

Method Summary

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)

Methods inherited from class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata

close, consume, isUp, logicalClusterIdsIncludingStale, metadata, start

Methods inherited from class io.confluent.kafka.multitenant.BasePhysicalClusterMetadata

getInstance

Methods inherited from class java.lang.Object

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

Field Detail

tenantLifecycleManager

public TenantLifecycleManager tenantLifecycleManager

sslCertificateManager

public SslCertificateManager sslCertificateManager

Constructor Detail

TopicBasedPhysicalClusterMetadata

public TopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics)

TopicBasedPhysicalClusterMetadata

public TopicBasedPhysicalClusterMetadata(org.apache.kafka.common.metrics.Metrics metrics,
                                         org.apache.kafka.common.utils.Time time)

Method Detail

configure

public 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. The caller of this method must call close() when done to remove the instance from the static map.

Specified by:

configure in interface org.apache.kafka.common.Configurable

Overrides:

configure in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<KafkaLogicalClusterMetadata>

Parameters:

configs - broker configuration

Throws:

org.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.

handleSocketServerInitialized

public void handleSocketServerInitialized()

start

public Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> start(Map<String,Object> interBrokerClientConfig,
                                                                           Collection<org.apache.kafka.common.Endpoint> endpoints)

dedicatedLogicalClusterId

public String dedicatedLogicalClusterId()

kafkaLogicalClusterIds

public Set<String> kafkaLogicalClusterIds()

logicalClusterIds

public Set<String> logicalClusterIds()

Specified by:

logicalClusterIds in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<KafkaLogicalClusterMetadata>