io.confluent.security.auth.dataplane

Class AuthnzTopicBasedPhysicalClusterMetadata

java.lang.Object

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

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

io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata

All Implemented Interfaces:

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

public class AuthnzTopicBasedPhysicalClusterMetadata
extends io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>

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 inherited from class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata

NUMBER_OF_NON_HC_TENANTS_METRIC_NAME, NUMBER_OF_TENANTS_METRIC_NAME

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
String	dedicatedLogicalClusterId()
void	handleSocketServerInitialized()
Set<String>	kafkaLogicalClusterIds()
Set<String>	logicalClusterIds()
Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>>	start(Map<String,Object> interBrokerClientConfigs, Collection<org.apache.kafka.common.Endpoint> endpoints)
void	updateClientConfigs(Map<String,Object> interBrokerClientConfigs)

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

close, configure, consume, isUp, logicalClusterIdsIncludingStale, metadata, start

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

getInstance, reconfigurableConfigs, reconfigure, validateReconfiguration

Methods inherited from class java.lang.Object

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

Constructor Detail

AuthnzTopicBasedPhysicalClusterMetadata

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

AuthnzTopicBasedPhysicalClusterMetadata

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

Method Detail

logicalClusterIds

public Set<String> logicalClusterIds()

Specified by:

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

handleSocketServerInitialized

public void handleSocketServerInitialized()

updateClientConfigs

public void updateClientConfigs(Map<String,Object> interBrokerClientConfigs)

start

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

dedicatedLogicalClusterId

public String dedicatedLogicalClusterId()

kafkaLogicalClusterIds

public Set<String> kafkaLogicalClusterIds()