Hierarchy For All Packages

Package Hierarchies:

• io.confluent.kafka.multitenant,
• io.confluent.security.auth.cloud,
• io.confluent.security.auth.dataplane,
• io.confluent.security.auth.ipFiltering,
• io.confluent.security.auth.metadata,
• io.confluent.security.auth.mtls,
• io.confluent.security.auth.provider,
• io.confluent.security.auth.provider.ldap,
• io.confluent.security.auth.store.cache,
• io.confluent.security.auth.store.external,
• io.confluent.security.auth.store.kafka,
• io.confluent.security.auth.utils,
• io.confluent.security.store,
• io.confluent.security.store.kafka,
• io.confluent.security.store.kafka.clients,
• io.confluent.security.store.kafka.coordinator

Class Hierarchy

• java.lang.Object
  • io.confluent.security.auth.store.cache.AbstractAuthCache (implements io.confluent.security.auth.metadata.AuthCache, io.confluent.security.store.KeyValueStore<K,V>, io.confluent.security.trustservice.store.TrustCache)
    • io.confluent.security.auth.cloud.CloudAuthCache
    • io.confluent.security.auth.store.cache.DefaultAuthCache
  • org.apache.kafka.common.config.AbstractConfig
    • io.confluent.security.store.kafka.KafkaStoreConfig
    • io.confluent.security.auth.provider.ldap.LdapConfig
  • org.apache.kafka.clients.consumer.internals.AbstractCoordinator (implements java.io.Closeable)
    • io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
  • io.confluent.security.auth.store.data.AuthKey
    • io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.DeserializerErrorForKey
  • io.confluent.security.auth.provider.AuthnzProvider (implements io.confluent.security.authorizer.provider.AccessRuleProvider, org.apache.kafka.server.authorizer.Authorizer)
  • io.confluent.security.auth.dataplane.AuthnzServerAuthorizer.AuthnzServerInfo (implements org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo)
  • io.confluent.security.auth.utils.AuthStoreMetrics
  • io.confluent.security.auth.utils.AuthStoreMetrics.LongGauge (implements org.apache.kafka.common.metrics.Gauge<T>)
  • io.confluent.security.auth.store.data.AuthValue
    • io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.DeserializerErrorForValue
  • io.confluent.security.auth.utils.AuthWriterUtils
  • io.confluent.kafka.server.plugins.auth.BaseMultiTenantSaslSecretsStore (implements org.apache.kafka.server.multitenant.MultiTenantSecretsStore)
    • io.confluent.security.auth.dataplane.AuthnzMultiTenantSaslSecretsStore
  • io.confluent.kafka.multitenant.BasePhysicalClusterMetadata<LCMType> (implements org.apache.kafka.server.multitenant.MultiTenantMetadata, org.apache.kafka.common.Reconfigurable)
    • io.confluent.kafka.multitenant.CommonTopicBasedPhysicalClusterMetadata<LCMType>
      • io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
  • io.confluent.security.auth.mtls.CaCertificatesUtils
  • io.confluent.security.store.kafka.clients.CachedRecord<K,V>
  • io.confluent.security.auth.provider.ConfluentProvider (implements io.confluent.security.authorizer.provider.AccessRuleProvider, io.confluent.security.authorizer.AclMigrationAware, io.confluent.security.authorizer.provider.Auditable, org.apache.kafka.server.authorizer.Authorizer, org.apache.kafka.common.ClusterResourceListener, io.confluent.security.authorizer.provider.GroupProvider, io.confluent.security.authorizer.provider.MetadataProvider, io.confluent.security.authorizer.provider.SharedProvider)
    • io.confluent.security.auth.dataplane.DataplaneProvider
  • io.confluent.security.auth.dataplane.DataplaneAuthWriter (implements io.confluent.security.auth.metadata.AuthWriter, java.io.Closeable, io.confluent.security.trustservice.store.TrustWriter, io.confluent.security.store.kafka.clients.Writer)
  • io.confluent.security.auth.dataplane.DataplaneBaseAuthStore (implements io.confluent.security.auth.metadata.AuthStore, io.confluent.security.store.kafka.clients.ConsumerListener<K,V>)
    • io.confluent.security.auth.dataplane.AuthnzAuthStore
    • io.confluent.security.auth.dataplane.DataplaneAuthStore
  • io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager (implements org.apache.kafka.common.utils.FileWatchService.Listener, org.apache.kafka.common.security.mtls.MTlsTruststoreManager)
  • io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde.DeserializationError
  • io.confluent.security.authorizer.EmbeddedAuthorizer (implements io.confluent.security.authorizer.Authorizer)
    • io.confluent.security.auth.dataplane.AuthnzServerAuthorizer
  • io.confluent.security.auth.ipFiltering.IpFilteringAuthCache (implements io.confluent.security.store.KeyValueStore<K,V>)
  • io.confluent.security.auth.ipFiltering.IpFilteringAuthStore (implements io.confluent.security.auth.metadata.AuthStore, io.confluent.security.store.kafka.clients.ConsumerListener<K,V>)
  • io.confluent.security.auth.ipFiltering.IpFilteringProvider (implements io.confluent.security.authorizer.provider.AccessRuleProvider)
  • io.confluent.security.store.kafka.clients.JsonSerde<T> (implements org.apache.kafka.common.Configurable, org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serde<T>, org.apache.kafka.common.serialization.Serializer<T>)
    • io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde<T>
  • io.confluent.security.auth.store.kafka.KafkaAuthStore (implements io.confluent.security.auth.metadata.AuthStore, io.confluent.security.store.kafka.clients.ConsumerListener<K,V>)
  • io.confluent.security.auth.store.kafka.KafkaAuthStore.BackOffDecorator<T>
  • io.confluent.security.auth.store.kafka.KafkaAuthWriter (implements io.confluent.security.auth.metadata.AuthWriter, io.confluent.security.store.kafka.clients.ConsumerListener<K,V>, io.confluent.security.trustservice.store.TrustWriter, io.confluent.security.store.kafka.clients.Writer)
  • io.confluent.security.store.kafka.clients.KafkaPartitionWriter<K,V>
  • io.confluent.security.store.kafka.clients.KafkaReader<K,V> (implements java.lang.Runnable)
    • io.confluent.security.auth.dataplane.DataplaneAuthReader<K,V>
  • io.confluent.security.store.kafka.clients.KafkaUtils
  • io.confluent.security.auth.provider.ldap.LdapAuthenticateCallbackHandler (implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler, org.apache.kafka.common.security.auth.AuthorizationIdProvider, java.io.Closeable)
  • io.confluent.security.auth.provider.ldap.LdapContextCreator
  • io.confluent.security.auth.provider.ldap.LdapGroupManager
  • io.confluent.security.auth.provider.ldap.LdapGroupProvider (implements io.confluent.security.authorizer.provider.GroupProvider)
  • io.confluent.security.auth.provider.ldap.LdapStore (implements io.confluent.security.auth.store.external.ExternalStore)
  • org.apache.kafka.server.multitenant.LogicalClusterMetadata
    • io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
  • io.confluent.security.store.kafka.coordinator.MetadataNodeManager (implements io.confluent.security.store.kafka.coordinator.MetadataServiceRebalanceListener)
  • io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
  • io.confluent.security.auth.utils.MetricsUtils
  • io.confluent.security.store.kafka.coordinator.NodeMetadata (implements java.lang.Comparable<T>)
  • io.confluent.security.auth.utils.RetryBackoff
  • io.confluent.security.auth.store.cache.ScopeAccessRuleStore (implements io.confluent.security.auth.store.cache.AccessRuleStore)
  • io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore (implements io.confluent.security.auth.store.cache.AccessRuleStore)
  • javax.net.SocketFactory
    • javax.net.ssl.SSLSocketFactory
      • org.apache.kafka.common.security.ssl.HostSslSocketFactory
        • io.confluent.security.auth.utils.ConfigurableSslSocketFactory
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.kafka.common.KafkaException
          • org.apache.kafka.common.errors.ApiException
            • io.confluent.security.authorizer.provider.ProviderFailedException
              • io.confluent.security.store.MetadataStoreException
            • org.apache.kafka.common.errors.RetriableException
              • org.apache.kafka.common.errors.NotCoordinatorException
                • io.confluent.security.store.NotMasterWriterException
          • io.confluent.security.auth.provider.ldap.LdapException

Interface Hierarchy

• io.confluent.security.auth.store.cache.AccessRuleStore
• java.lang.AutoCloseable
  • java.io.Closeable
    • io.confluent.security.auth.metadata.PasswordVerifier (also extends org.apache.kafka.common.Configurable)
• org.apache.kafka.common.Configurable
  • io.confluent.security.auth.store.external.ExternalStore
  • io.confluent.security.auth.metadata.PasswordVerifier (also extends java.io.Closeable)
• io.confluent.security.store.kafka.clients.ConsumerListener<K,V>
• io.confluent.security.auth.store.external.ExternalStoreListener<K,V>
• io.confluent.security.store.kafka.coordinator.MetadataServiceRebalanceListener
• io.confluent.security.store.kafka.clients.StatusListener
• io.confluent.security.store.kafka.clients.Writer

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • io.confluent.security.auth.provider.ldap.LdapConfig.SearchMode
    • io.confluent.security.auth.provider.ldap.LdapPrincipalMapping
    • io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment.AssignmentError
    • io.confluent.security.auth.metadata.PasswordVerifier.Result