Hierarchy For All Packages

Package Hierarchies:

• io.confluent.common,
• io.confluent.common.security.utils,
• io.confluent.kafka.link,
• io.confluent.kafka.multitenant,
• io.confluent.kafka.multitenant.assignor,
• io.confluent.kafka.multitenant.audit,
• io.confluent.kafka.multitenant.authorizer,
• io.confluent.kafka.multitenant.metrics,
• io.confluent.kafka.multitenant.metrics.utils,
• io.confluent.kafka.multitenant.quota,
• io.confluent.kafka.multitenant.schema,
• io.confluent.kafka.multitenant.serde,
• io.confluent.kafka.multitenant.tools,
• io.confluent.kafka.multitenant.utils,
• io.confluent.kafka.security.audit.event,
• io.confluent.kafka.security.authenticator,
• io.confluent.kafka.security.authorizer,
• io.confluent.kafka.security.authorizer.acl,
• io.confluent.kafka.security.ldap.authorizer,
• io.confluent.kafka.server.plugins.auth,
• io.confluent.kafka.server.plugins.auth.oauth,
• io.confluent.kafka.server.plugins.auth.token,
• io.confluent.kafka.server.plugins.policy,
• io.confluent.kafka.server.plugins.ssl,
• io.confluent.kafka.traffic,
• io.confluent.security.auth.dataplane,
• io.confluent.security.auth.provider.oauth,
• io.confluent.security.mtls

Class Hierarchy

• java.lang.Object
  • org.apache.kafka.common.config.AbstractConfig
    • io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
      • io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
      • io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
      • io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
    • io.confluent.kafka.server.plugins.auth.oauth.JwtAuthenticatorConfig
    • io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig
  • org.apache.kafka.server.metrics.AbstractSensorBuilder<C,S>
    • io.confluent.kafka.multitenant.metrics.AbstractConnectionSensorBuilder
      • io.confluent.kafka.multitenant.metrics.ApiKeyConnectionSensorBuilder
      • io.confluent.kafka.multitenant.metrics.ConnectionSensorBuilder
      • io.confluent.kafka.multitenant.metrics.IpConnectionSensorBuilder
    • org.apache.kafka.server.metrics.ApiSensorBuilder
      • io.confluent.kafka.multitenant.metrics.FetchApiSensorBuilder
    • io.confluent.kafka.multitenant.metrics.HotPartitionSensorBuilder
    • io.confluent.kafka.multitenant.metrics.IpFailedAuthenticationByIpSensorBuilder
    • io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
  • org.apache.kafka.server.metrics.AbstractSensorCreator
    • io.confluent.kafka.multitenant.metrics.AbstractPartitionSensorCreator
    • org.apache.kafka.server.metrics.ApiSensorBuilder.AbstractApiSensorCreator
      • io.confluent.kafka.multitenant.metrics.FetchResponseSensorCreator
  • kafka.security.authorizer.AclAuthorizer (implements org.apache.kafka.server.authorizer.Authorizer, kafka.utils.Logging)
    • io.confluent.kafka.security.authorizer.acl.AclProvider (implements io.confluent.kafka.security.authorizer.acl.ExtendedAccessRuleProvider)
  • io.confluent.kafka.security.authorizer.acl.AclMapper
  • io.confluent.kafka.server.plugins.policy.AlterConfigPolicy (implements kafka.server.link.ClusterLinkAlterConfigPolicy)
  • io.confluent.kafka.server.plugins.auth.AuthAttemptCache
  • io.confluent.kafka.server.plugins.auth.BaseMultiTenantSaslSecretsStore (implements org.apache.kafka.server.multitenant.MultiTenantSecretsStore)
    • io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
  • 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.kafka.multitenant.TopicBasedPhysicalClusterMetadata
    • io.confluent.kafka.multitenant.PhysicalClusterMetadata
  • io.confluent.kafka.link.ClusterLinkApis
  • io.confluent.kafka.link.ClusterLinkInterceptor (implements org.apache.kafka.clients.ClientInterceptor, org.apache.kafka.common.Configurable)
  • io.confluent.kafka.server.plugins.auth.token.CompositeBearerValidatorCallbackHandler (implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler)
  • io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent (implements org.apache.kafka.server.audit.AuthenticationEvent)
  • io.confluent.kafka.server.plugins.ssl.ConfluentTrustProviderCreator (implements org.apache.kafka.common.security.auth.SecurityProviderCreator)
  • io.confluent.kafka.multitenant.metrics.ConnectionInformationSensorBuilder
  • io.confluent.kafka.multitenant.metrics.ConnectionSensors
  • io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy (implements org.apache.kafka.server.interceptor.ClusterLinkInterceptor, org.apache.kafka.server.policy.CreateClusterLinkPolicy, org.apache.kafka.common.Reconfigurable)
  • io.confluent.kafka.server.plugins.policy.CreateTopicPolicy (implements org.apache.kafka.metadata.ConfluentPartitionsPerTopicListener, org.apache.kafka.server.policy.CreateTopicPolicy, org.apache.kafka.server.interceptor.Monitorable, org.apache.kafka.server.multitenant.MultiTenantMetadataPublisher, org.apache.kafka.common.Reconfigurable)
  • io.confluent.kafka.server.plugins.auth.DeconstructedPbkdf2Hash
  • io.confluent.kafka.server.plugins.auth.DefaultDataPolicyAuthenticator
  • io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext
  • io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext.Builder
  • io.confluent.security.mtls.DefaultMTlsConnectionManager (implements org.apache.kafka.common.security.mtls.MTlsConnectionManager)
  • io.confluent.kafka.multitenant.audit.DefaultTenantSanitizer (implements io.confluent.kafka.multitenant.audit.TenantSanitizer)
  • io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore (implements org.apache.kafka.server.multitenant.UserMetadataStore)
  • io.confluent.kafka.multitenant.tools.DeleteAclsForMultiTenantPrincipal
  • java.util.Dictionary<K,V>
    • java.util.Hashtable<K,V> (implements java.lang.Cloneable, java.util.Map<K,V>, java.io.Serializable)
      • java.util.Properties
        • java.security.Provider
          • io.confluent.kafka.server.plugins.ssl.ConfluentTrustProvider
          • io.confluent.kafka.server.plugins.auth.FileBasedSaslServerProvider
          • io.confluent.kafka.server.plugins.auth.TopicBasedSaslServerProvider
  • io.confluent.security.authorizer.EmbeddedAuthorizer (implements io.confluent.security.authorizer.Authorizer)
    • io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer (implements org.apache.kafka.server.authorizer.Authorizer, org.apache.kafka.metadata.authorizer.ClusterMetadataAuthorizer, org.apache.kafka.common.Reconfigurable)
      • io.confluent.kafka.security.ldap.authorizer.LdapAuthorizer
      • io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
  • io.confluent.common.EndPoint
  • io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler (implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler)
  • io.confluent.kafka.multitenant.serde.EventsMetadataHeader
  • io.confluent.kafka.multitenant.metrics.FailedAuthSensors
  • io.confluent.kafka.server.plugins.auth.FileBasedLoginModule (implements javax.security.auth.spi.LoginModule)
  • io.confluent.kafka.multitenant.metrics.HotPartitionManager (implements org.apache.kafka.common.Configurable)
  • io.confluent.kafka.multitenant.metrics.HotPartitionSensors
  • io.confluent.common.InterClusterConnection
  • io.confluent.security.authentication.oauthbearer.JwtIssuer
    • io.confluent.security.auth.dataplane.JwtIssuerAuthCache (implements org.apache.kafka.common.Configurable)
  • io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder
  • io.confluent.kafka.multitenant.KafkaLogicalClusterMetadataLoader (implements org.apache.kafka.server.multitenant.MultiTenantMetadataLoader)
  • io.confluent.kafka.multitenant.KafkaLogicalClusterMetadataLoaderMetrics
  • io.confluent.kafka.server.plugins.auth.oauth.KafkaVerificationKeyResolver (implements org.jose4j.keys.resolvers.VerificationKeyResolver)
  • io.confluent.kafka.link.LinkContext (implements org.apache.kafka.common.protocol.MessageContext)
  • io.confluent.kafka.multitenant.serde.LogicalClusterMetadataRecord
  • io.confluent.kafka.multitenant.serde.LogicalClusterMetadataRecordDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore (implements io.confluent.security.auth.metadata.AuthStore)
  • io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache (implements io.confluent.security.store.KeyValueStore<K,V>, io.confluent.security.trustservice.store.TrustCache)
  • io.confluent.kafka.link.MultiTenantAclBindingFilterTransformer (implements kafka.server.link.AclBindingFilterTransformer)
  • io.confluent.kafka.multitenant.schema.MultiTenantApis
  • io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer.TenantAuthorizerMetrics
  • io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
  • io.confluent.kafka.multitenant.MultiTenantInterceptor (implements org.apache.kafka.server.interceptor.BrokerInterceptor)
  • io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
  • io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder (implements org.apache.kafka.common.Configurable, org.apache.kafka.common.security.auth.KafkaPrincipalBuilder, org.apache.kafka.common.security.auth.KafkaPrincipalSerde)
  • io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsLoader
  • io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerServerLoginCallbackHandler (implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler)
  • io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler (implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler)
  • io.confluent.kafka.security.authenticator.OAuthKafkaPrincipalBuilder (implements org.apache.kafka.common.Configurable, org.apache.kafka.common.security.auth.KafkaPrincipalBuilder, org.apache.kafka.common.security.auth.KafkaPrincipalSerde)
  • io.confluent.kafka.multitenant.metrics.utils.PartitionMetricUtils
  • io.confluent.kafka.multitenant.metrics.PartitionSensors
  • io.confluent.kafka.server.plugins.auth.Pbkdf2
  • io.confluent.kafka.server.plugins.auth.PbkdfBase64
  • io.confluent.common.security.utils.PemUtils
  • io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
    • io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator
    • io.confluent.kafka.server.plugins.auth.TopicBasedPlainSaslAuthenticator
  • io.confluent.kafka.server.plugins.auth.PlainSaslCredentials
  • io.confluent.kafka.server.plugins.auth.PlainSaslCredentials.Builder
  • io.confluent.kafka.server.plugins.auth.PlainSaslServer (implements io.confluent.kafka.multitenant.MultiTenantSaslServer)
  • io.confluent.kafka.server.plugins.auth.PlainSaslServer.PlainSaslServerFactory (implements javax.security.sasl.SaslServerFactory)
    • io.confluent.kafka.server.plugins.auth.FileBasedSaslServerFactory
    • io.confluent.kafka.server.plugins.auth.TopicBasedSaslServerFactory
  • io.confluent.kafka.server.plugins.policy.PolicyUtils
  • org.apache.kafka.common.requests.RequestContext (implements org.apache.kafka.server.authorizer.AuthorizableRequestContext)
    • io.confluent.kafka.multitenant.MultiTenantRequestContext
  • io.confluent.kafka.multitenant.serde.RoleBindingMetadataFormatter (implements org.apache.kafka.common.MessageFormatter)
  • io.confluent.kafka.multitenant.SpiffeIdPrincipalExtractor (implements org.apache.kafka.common.Configurable)
  • io.confluent.kafka.multitenant.SslCertificateManager
  • io.confluent.kafka.multitenant.SslCertificateSpecification
  • io.confluent.kafka.security.authorizer.acl.StandardAclProvider (implements io.confluent.kafka.security.authorizer.acl.ExtendedAccessRuleProvider)
  • io.confluent.kafka.multitenant.authorizer.TenantAclProvider (implements io.confluent.security.authorizer.provider.AccessRuleProvider, org.apache.kafka.common.Reconfigurable)
  • io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer (implements org.apache.kafka.server.quota.MultiTenantQuotaConsumer)
  • io.confluent.kafka.multitenant.quota.TenantClientQuotaFormatter (implements org.apache.kafka.common.MessageFormatter)
  • io.confluent.kafka.multitenant.schema.TenantContext (implements org.apache.kafka.common.protocol.MessageContext)
  • io.confluent.kafka.multitenant.TenantLifecycleManager
  • io.confluent.kafka.multitenant.metrics.TenantMetrics
  • io.confluent.kafka.multitenant.metrics.TenantMetrics.IpMetricsContext (implements org.apache.kafka.server.metrics.MetricsBuilderContext)
  • io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantLevelMetricsContext (implements org.apache.kafka.server.metrics.MetricsBuilderContext)
  • io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext (implements org.apache.kafka.server.metrics.MetricsBuilderContext)
    • io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeyMetricsContext
    • io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext
    • io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantClientIdsMetricsContext
    • io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantConnectionInformationMetricsContext
    • io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantIpMetricsContext
  • io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor (implements kafka.assignor.TopicReplicaAssignor)
  • io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo
  • io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder (implements kafka.assignor.TopicReplicaAssignorBuilder)
  • io.confluent.kafka.multitenant.quota.TenantQuotaCallback (implements org.apache.kafka.server.quota.ClientQuotaCallback, org.apache.kafka.server.quota.ClusterLevelQuotaCallback, org.apache.kafka.common.Reconfigurable)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • io.confluent.kafka.multitenant.audit.DefaultTenantSanitizer.NotTenantPrefixedException
  • io.confluent.kafka.multitenant.metrics.utils.TimeIntervalMetricSampler (implements io.confluent.kafka.multitenant.metrics.utils.MetricSampler)
  • io.confluent.kafka.server.plugins.auth.token.TokenBearerServerLoginCallbackHandler (implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler)
  • io.confluent.kafka.server.plugins.auth.token.TokenBearerValidatorCallbackHandler (implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler)
  • io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule (implements javax.security.auth.spi.LoginModule)
  • io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater (implements org.apache.kafka.server.traffic.TrafficNetworkIdRoutesUpdater)
  • io.confluent.kafka.traffic.TrafficNetworkIdAllowedRoutes
  • io.confluent.kafka.server.plugins.auth.TrafficNetworkIdAuthenticator
  • javax.net.ssl.TrustManagerFactorySpi
    • io.confluent.kafka.server.plugins.ssl.ConfluentTrustManagerFactory
      • io.confluent.kafka.server.plugins.ssl.NetworkLinkTrustManagerFactory
  • io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler (implements kafka.common.DeletionEventHandler)
  • io.confluent.kafka.server.plugins.auth.UserMetaDataKey
  • io.confluent.kafka.server.plugins.auth.UserMetaDataValue
  • io.confluent.kafka.multitenant.utils.Utils
  • javax.net.ssl.X509ExtendedTrustManager (implements javax.net.ssl.X509TrustManager)
    • io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager
      • io.confluent.kafka.server.plugins.ssl.NetworkLinkTrustManager

Interface Hierarchy

• java.lang.AutoCloseable
  • java.io.Closeable
    • io.confluent.security.authorizer.provider.Provider (also extends org.apache.kafka.common.Configurable)
      • io.confluent.security.authorizer.provider.AccessRuleProvider
        • io.confluent.kafka.security.authorizer.acl.ExtendedAccessRuleProvider
• org.apache.kafka.common.Configurable
  • io.confluent.security.authorizer.provider.Provider (also extends java.io.Closeable)
    • io.confluent.security.authorizer.provider.AccessRuleProvider
      • io.confluent.kafka.security.authorizer.acl.ExtendedAccessRuleProvider
  • io.confluent.kafka.multitenant.audit.TenantSanitizer
• io.confluent.kafka.multitenant.metrics.utils.MetricSampler
• io.confluent.kafka.multitenant.assignor.RackMetadata
• javax.security.sasl.SaslServer
  • io.confluent.kafka.security.auth.ConfluentSaslServer
    • io.confluent.kafka.multitenant.MultiTenantSaslServer
• io.confluent.kafka.server.plugins.auth.SaslServerSupplier

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • io.confluent.kafka.server.plugins.auth.SniValidationMode
    • io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore.State
    • io.confluent.kafka.server.plugins.auth.DefaultDataPolicyValidationMode
    • io.confluent.kafka.server.plugins.auth.TrafficNetworkIdValidationMode
    • io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler.State
    • io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater.State
    • io.confluent.kafka.multitenant.PhysicalClusterMetadata.State
    • io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer.State