Class CpcLogicalClusterMetadataLoader

java.lang.Object

io.confluent.kafka.multitenant.KafkaLogicalClusterMetadataLoader

io.confluent.kafka.cpc.multitenant.CpcLogicalClusterMetadataLoader

All Implemented Interfaces:

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

public class CpcLogicalClusterMetadataLoader
extends KafkaLogicalClusterMetadataLoader

Controller-side loader for CPC multi-tenancy. Extends the Cloud loader with JSON deserialization, CPC config keys, and topic auto-creation.

Constructor Summary

Constructors

Constructor	Description
CpcLogicalClusterMetadataLoader(org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.common.utils.Time time)

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs)

Methods inherited from class KafkaLogicalClusterMetadataLoader

start, subscribe

Methods inherited from class Object

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

Constructor Details

CpcLogicalClusterMetadataLoader

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

Method Details

configure

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

Specified by:

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

Overrides:

configure in class KafkaLogicalClusterMetadataLoader

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class KafkaLogicalClusterMetadataLoader

Throws:

Exception