Class AuthnzTopicBasedPhysicalClusterMetadata

java.lang.Object
io.confluent.kafka.multitenant.BasePhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>
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

    Fields inherited from interface org.apache.kafka.server.multitenant.MultiTenantMetadata

    CONFLUENT_ENV_ID

  • Constructor Summary

    Constructors
    Constructor
    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
    Description
    String
    dedicatedLogicalClusterId()
     
    boolean
    isUp()
     
    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
    startClients(Function<String, org.apache.kafka.clients.admin.Admin> adminClientSupplier)
     

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

    close, configure, consume, 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

    Methods inherited from interface org.apache.kafka.server.multitenant.MultiTenantMetadata

    ensureOpen, firstActiveUserLkcMetadata, registerTenantCallback, registerTenantDeactivatedCallback, registerTenantMetadataUpdateCallback

  • Constructor Details

    • 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 Details

    • isUp

      public boolean isUp()

    • logicalClusterIds

      public Set<String> logicalClusterIds()
      Specified by:
      logicalClusterIds in interface org.apache.kafka.server.multitenant.MultiTenantMetadata
      Specified by:
      logicalClusterIds in class io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<NonKafkaLogicalClusterMetadata>

    • startClients

      public void startClients(Function<String, org.apache.kafka.clients.admin.Admin> adminClientSupplier)

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