io.confluent.kafka.multitenant

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

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 and Description
KafkaLogicalClusterMetadataLoader(Map<String,?> baseClientProperties, 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 and Description
void	close()
void	configure(Map<String,?> configs)
Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>>	start(Collection<org.apache.kafka.common.Endpoint> endpoints, List<org.apache.kafka.server.multitenant.MultiTenantMetadataPublisher> multiTenantMetadataPublishers)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaLogicalClusterMetadataLoader

public KafkaLogicalClusterMetadataLoader(Map<String,?> baseClientProperties,
                                         org.apache.kafka.common.metrics.Metrics metrics,
                                         org.apache.kafka.common.utils.Time time)

The constructor used during Kafka startup. DO NOT DELETE.

Parameters:

baseClientProperties - client configurations used as a base for the internal topic consumer

metrics - the global Metrics instance

time - an implementation of Time

See Also:

ConfluentConfigs.buildMultiTenantMetadataLoader(AbstractConfig, Map, Metrics)

Method Detail

start

public Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> start(Collection<org.apache.kafka.common.Endpoint> endpoints,
                                                                           List<org.apache.kafka.server.multitenant.MultiTenantMetadataPublisher> multiTenantMetadataPublishers)

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