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.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.LCMPair, io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata.State

Field Summary

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

backgroundUpdatesExecutorService, CLOSE_TIMEOUT_MS, lcLog, LOG, logConsumerState, logicalClusterIds, logicalClusterMap, maxPartitionRetryDelayMs, multitenantListenerNames, NUMBER_OF_TENANTS_METRIC_NAME, time, topicName

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

INSTANCES

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()
protected void	ensureOpen()
protected org.apache.kafka.common.metrics.Sensor	getEndToEndSensor()
protected String	getSessionUuid(Map<String,?> configs)
protected org.apache.kafka.common.metrics.Sensor	getStartSensor()
protected String	getTopicClientId(Map<String,?> configs)
protected String	getTopicConfig()
void	handleSocketServerInitialized(String endpoint)
Set<String>	kafkaLogicalClusterIds()
Set<String>	logicalClusterIds()
protected NonKafkaLogicalClusterMetadata	parseLCM(org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)
protected void	recordEndToEndSensor(NonKafkaLogicalClusterMetadata newLcm)
protected void	shutdown() After this method is called, querying the cache will throw IllegalStateException
Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>>	start(Map<String,Object> interBrokerClientConfigs, Collection<org.apache.kafka.common.Endpoint> endpoints)
protected void	startLog()

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

close, configure, consume, createKafkaBasedLog, ensureNonTerminalState, isStartingOrRunningState, isUp, logicalClusterIdsIncludingStale, metadata, postUpdateBookkeeping, start, updateLogicalCluster, updateNumberOfTenantsMetric

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

getInstance

Methods inherited from class java.lang.Object

clone, equals, finalize, 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

getSessionUuid

protected String getSessionUuid(Map<String,?> configs)

Specified by:

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

getStartSensor

protected org.apache.kafka.common.metrics.Sensor getStartSensor()

Specified by:

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

getEndToEndSensor

protected org.apache.kafka.common.metrics.Sensor getEndToEndSensor()

Specified by:

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

getTopicConfig

protected String getTopicConfig()

Specified by:

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

getTopicClientId

protected String getTopicClientId(Map<String,?> configs)

Specified by:

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

shutdown

protected void shutdown()

After this method is called, querying the cache will throw IllegalStateException

Specified by:

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

ensureOpen

protected void ensureOpen()

Specified by:

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

logicalClusterIds

public Set<String> logicalClusterIds()

Specified by:

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

handleSocketServerInitialized

public void handleSocketServerInitialized(String endpoint)

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()

parseLCM

protected NonKafkaLogicalClusterMetadata parseLCM(org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)

Specified by:

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

recordEndToEndSensor

protected void recordEndToEndSensor(NonKafkaLogicalClusterMetadata newLcm)

Specified by:

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

startLog

protected void startLog()

Specified by:

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