Class KafkaLogicalClusterMetadataLoader

java.lang.Object

io.confluent.kafka.multitenant.KafkaLogicalClusterMetadataLoader

All Implemented Interfaces:

AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.server.multitenant.MultiTenantMetadataLoader

Direct Known Subclasses:

CpcLogicalClusterMetadataLoader

public class KafkaLogicalClusterMetadataLoader
extends Object
implements org.apache.kafka.server.multitenant.MultiTenantMetadataLoader

This class loads the LogicalClusterMetadata from the topic configured by ConfluentConfigs.CDC_LKC_METADATA_TOPIC_CONFIG.

Constructor Summary

Constructors

Constructor	Description
KafkaLogicalClusterMetadataLoader(org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.common.utils.Time time)	The constructor used during Kafka startup.

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs)
CompletableFuture<Void>	start(Map<String,Object> interBrokerClientConfigs)
void	subscribe(org.apache.kafka.server.multitenant.MultiTenantMetadataPublisher publisher)

Methods inherited from class Object

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

Constructor Details

KafkaLogicalClusterMetadataLoader

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

The constructor used during Kafka startup. DO NOT DELETE.

Parameters:

metrics - the global Metrics instance

time - an implementation of Time

See Also:

• ConfluentConfigs.buildMultiTenantMetadataLoader(AbstractConfig, Metrics)

Method Details

subscribe

public void subscribe(org.apache.kafka.server.multitenant.MultiTenantMetadataPublisher publisher)

Specified by:

subscribe in interface org.apache.kafka.server.multitenant.MultiTenantMetadataLoader

start

public CompletableFuture<Void> start(Map<String,Object> interBrokerClientConfigs)

Specified by:

start in interface org.apache.kafka.server.multitenant.MultiTenantMetadataLoader

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

configure

public void configure(Map<String,?> configs)

Specified by:

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