Index

A B C D E F G H I J K L M N O P Q R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

abort() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule

abort() - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule

AbstractConnectionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics

AbstractConnectionSensorBuilder(Metrics, TenantMetrics.TenantMetricsContext) - Constructor for class io.confluent.kafka.multitenant.metrics.AbstractConnectionSensorBuilder

AbstractPartitionSensorCreator - Class in io.confluent.kafka.multitenant.metrics

AbstractPartitionSensorCreator(String, String, String, TopicPartition) - Constructor for class io.confluent.kafka.multitenant.metrics.AbstractPartitionSensorCreator

AbstractPolicyConfig - Class in io.confluent.kafka.server.plugins.policy

accessRule(StandardAcl) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper

ACL_SYNC_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

ACL_SYNC_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

aclCount() - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

AclMapper - Class in io.confluent.kafka.security.authorizer.acl

Maps Kafka ACL and related classes to Confluent cross-component authorization classes.

AclMapper() - Constructor for class io.confluent.kafka.security.authorizer.acl.AclMapper

aclMutatorOrException() - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

aclOperation(Operation) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper

acls(AclBindingFilter) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

acls(AclBindingFilter) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

acls(AclBindingFilter, AclState) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

acls(AclBindingFilter, AclState) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

activeNodeUrls(String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

addAdditionalTags(Map<String, String>) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

addMatchingRules(ResourceAuthorizeRules, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in interface io.confluent.kafka.security.authorizer.acl.ExtendedAccessRuleProvider

addMatchingRules(ResourceAuthorizeRules, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider

addMatchingRules(ResourceAuthorizeRules, KafkaPrincipal, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

addMatchingRules(ResourceAuthorizeRules, KafkaPrincipal, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in interface io.confluent.kafka.security.authorizer.acl.ExtendedAccessRuleProvider

addTenantPrefix(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext

addTenantPrefix(String, String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext

addTenantPrefixNullable(String, String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext

addTenantPrefixToPrincipal(String, String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext

ALLOW_LEGACY_BOOTSTRAP - Enum constant in enum class io.confluent.kafka.server.plugins.auth.SniValidationMode

allowedDNSDomainSuffixes() - Method in class io.confluent.kafka.traffic.TrafficNetworkIdAllowedRoutes

allowedNetworkIds() - Method in class io.confluent.kafka.traffic.TrafficNetworkIdAllowedRoutes

ALTER_ENABLE_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

AlterConfigPolicy - Class in io.confluent.kafka.server.plugins.policy

AlterConfigPolicy() - Constructor for class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy

AlterConfigPolicy.ClusterPolicyConfig - Class in io.confluent.kafka.server.plugins.policy

AlterConfigPolicy.GroupPolicyConfig - Class in io.confluent.kafka.server.plugins.policy

API_KEYS_MAX_VERSION_SENSOR_NAME - Static variable in class io.confluent.kafka.multitenant.metrics.ApiKeysVersionSensorBuilder

apiKey() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

ApiKeyConnectionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics

ApiKeyConnectionSensorBuilder(Metrics, MultiTenantPrincipal) - Constructor for class io.confluent.kafka.multitenant.metrics.ApiKeyConnectionSensorBuilder

ApiKeyMetricsContext(MultiTenantPrincipal) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeyMetricsContext

ApiKeysVersionContext(ApiKeys) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeysVersionContext

ApiKeysVersionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics

ApiKeysVersionSensorBuilder(Metrics, ApiKeys) - Constructor for class io.confluent.kafka.multitenant.metrics.ApiKeysVersionSensorBuilder

ApiKeysVersionSensors - Class in io.confluent.kafka.multitenant.metrics

ApiKeysVersionSensors(Sensor) - Constructor for class io.confluent.kafka.multitenant.metrics.ApiKeysVersionSensors

ApiSensorsMetricsRequestContext(TenantMetrics.MetricsRequestContext) - Constructor for record class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiSensorsMetricsRequestContext

Creates an instance of a ApiSensorsMetricsRequestContext record class.

applyAclChanges(Map<Uuid, Optional<ConfluentStandardAcl>>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

applyAclChanges(Map<Uuid, Optional<ConfluentStandardAcl>>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

appName() - Method in class io.confluent.kafka.multitenant.serde.EventsMetadataHeader

asAuthorizer() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

asAuthorizer() - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider

audience() - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache

audience(Set<String>) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder

AUTH_CONNECTION_COUNT - Static variable in class io.confluent.kafka.multitenant.metrics.ApiKeyConnectionSensorBuilder

AUTH_RATE - Static variable in class io.confluent.kafka.multitenant.metrics.ApiKeyConnectionSensorBuilder

AuthAttemptCache - Class in io.confluent.kafka.server.plugins.auth

Caches authentication attempts, whether successful or unsuccessful.

AuthAttemptCache(long, int, Time, int, String, Metrics) - Constructor for class io.confluent.kafka.server.plugins.auth.AuthAttemptCache

Create an AuthAttemptCache.

AuthAttemptCache(String, Metrics) - Constructor for class io.confluent.kafka.server.plugins.auth.AuthAttemptCache

Create an AuthAttemptCache using default values of ttl and maxSize

authCache() - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

authenticate(DefaultDataPolicyContext) - Method in class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyAuthenticator

authenticate(PlainSaslCredentials) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator

Authenticate user by checking username, password, cluster id and network ID.

authenticate(Optional<String>, String) - Method in class io.confluent.kafka.server.plugins.auth.TrafficNetworkIdAuthenticator

authenticationContext() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

authenticationException() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

authenticationId() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer

authenticationId() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

authorize(AuthorizableRequestContext, List<Action>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

authorize(AuthorizableRequestContext, List<Action>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

authorizeByResourceType(AuthorizableRequestContext, AclOperation, ResourceType) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

authorizerPlugin - Variable in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

AVAILABILITY_CHECK_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

AVAILABILITY_CHECK_MS_MAX_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

AVAILABILITY_CHECK_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

AVAILABILITY_CHECK_MS_MIN_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

B

BASE_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

BASE_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

brokerFqdnBuilder() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

brokerRack() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

build() - Method in class io.confluent.kafka.multitenant.metrics.ApiKeyConnectionSensorBuilder

build() - Method in class io.confluent.kafka.multitenant.metrics.ApiKeysVersionSensorBuilder

build() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensorBuilder

build() - Method in class io.confluent.kafka.multitenant.metrics.FetchApiSensorBuilder

build() - Method in class io.confluent.kafka.multitenant.metrics.HotPartitionSensorBuilder

build() - Method in class io.confluent.kafka.multitenant.metrics.IpConnectionSensorBuilder

build() - Method in class io.confluent.kafka.multitenant.metrics.IpFailedAuthenticationByIpSensorBuilder

build() - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder

build() - Method in class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext.Builder

build() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials.Builder

build() - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder

Construct new JwtIssuerAuthCache instance.

build(AuthenticationContext) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder

build(AuthenticationContext) - Method in class io.confluent.kafka.security.authenticator.OAuthKafkaPrincipalBuilder

buildAction(Action, ResourcePattern, KafkaPrincipal, Scope) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

buildAction(Action, ResourcePattern, KafkaPrincipal, Scope) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

builder() - Static method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache

Builder() - Constructor for class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext.Builder

Builder(String, String) - Constructor for class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials.Builder

Builder(String, String, PathAwareSniHostName, String, String, String, SaslInternalConfigs.NetworkType, Boolean) - Constructor for class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials.Builder

Builder(String, SaslInternalConfigs.NetworkType, Boolean) - Constructor for class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext.Builder

Builder(String, SaslInternalConfigs.NetworkType, Boolean, Sensor) - Constructor for class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext.Builder

Builder(Optional<String>, Optional<SaslInternalConfigs.NetworkType>, Optional<Boolean>, Sensor) - Constructor for class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext.Builder

buildResponseSend(AbstractResponse) - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

C

CALLING_RESOURCE_IDENTITY_CLAIM_KEY - Static variable in class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler

CallingResourceIdentityTypeExtractor - Class in io.confluent.kafka.multitenant

CallingResourceIdentityTypeExtractor() - Constructor for class io.confluent.kafka.multitenant.CallingResourceIdentityTypeExtractor

CCLOUD_INTERNAL_USER - Static variable in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder

checkClientTrusted(X509Certificate[], String) - Method in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

checkClientTrusted(X509Certificate[], String, Socket) - Method in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

checkClientTrusted(X509Certificate[], String, SSLEngine) - Method in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

checkServerTrusted(X509Certificate[], String) - Method in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

checkServerTrusted(X509Certificate[], String, Socket) - Method in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

checkServerTrusted(X509Certificate[], String, SSLEngine) - Method in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

CLEANUP_POLICY_ALLOWED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

cleanUpTenantDynamicQuotas(List<Map<String, String>>, Set<String>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

clearPending() - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

clearTenantContext() - Method in class io.confluent.kafka.link.ClusterLinkInterceptor

clientId() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

clientLogicalClusterId() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer

clientLogicalClusterId() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

close() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

close() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadataLoader

close() - Method in class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer

close() - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

close() - Method in class io.confluent.kafka.multitenant.serde.RoleBindingMetadataFormatter

close() - Method in class io.confluent.kafka.multitenant.SslCertificateManager

close() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager

close() - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider

close() - Method in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

close() - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

close() - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerServerLoginCallbackHandler

close() - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler

close() - Method in class io.confluent.kafka.server.plugins.auth.token.CompositeBearerValidatorCallbackHandler

close() - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerServerLoginCallbackHandler

close() - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerValidatorCallbackHandler

close() - Method in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

close() - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy

close() - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

close() - Method in class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater

close() - Method in class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler

close(String) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

closeConnections(PublicCredential) - Method in class io.confluent.security.mtls.DefaultMTlsConnectionManager

CLOSED - Enum constant in enum class io.confluent.kafka.multitenant.PhysicalClusterMetadata.State

CLOSED - Enum constant in enum class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer.State

CLOSED - Enum constant in enum class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore.State

CLOSED - Enum constant in enum class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater.State

cluster() - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

CLUSTER_LINK_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

clusterId(String) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator

ClusterLinkApis - Class in io.confluent.kafka.link

ClusterLinkApis() - Constructor for class io.confluent.kafka.link.ClusterLinkApis

ClusterLinkInterceptor - Class in io.confluent.kafka.link

ClusterLinkInterceptor() - Constructor for class io.confluent.kafka.link.ClusterLinkInterceptor

ClusterLinkPolicyConfig - Class in io.confluent.kafka.server.plugins.policy

ClusterLinkPolicyConfig(Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

clusterLinkRestrictTopicConfigs(Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy

clusterLinkValidateTopicConfigs(Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy

clusterQuotaLimit(ClientQuotaType, Map<String, String>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

commit() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule

commit() - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule

completeInitialLoad() - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

completeInitialLoad(Exception) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

CompositeBearerValidatorCallbackHandler - Class in io.confluent.kafka.server.plugins.auth.token

A CallbackHandler that recognizes CompositeBearerValidatorCallbackHandler for validating Authentication Tokens issued by Confluent and external Identity Provider.

CompositeBearerValidatorCallbackHandler() - Constructor for class io.confluent.kafka.server.plugins.auth.token.CompositeBearerValidatorCallbackHandler

computeAssignmentForExistingTopic(TopicReplicaAssignor.NewPartitions, Optional<TopicPlacement>, Set<Integer>) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor

Computes the replica assignment for an existing topic that is about to have new partitions created on it (CreatePartitions request).

computeAssignmentForNewTopic(TopicReplicaAssignor.NewPartitions, Optional<TopicPlacement>, Set<Integer>) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor

Computes the replica assignment for a topic that's about to be created (CreateTopics request).

config() - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

CONFIG_PREFIX - Static variable in class io.confluent.kafka.server.plugins.auth.oauth.JwtAuthenticatorConfig

CONFIG_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

configEntryOption(List<AppConfigurationEntry>, String, String) - Static method in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator

configure(Map<String, ?>) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.audit.DefaultTenantSanitizer

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.CallingResourceIdentityTypeExtractor

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadataLoader

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.metrics.HotPartitionManager

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

Loads the cache and starts listening for directory events in directory specified in ConfluentConfigs.MULTITENANT_METADATA_DIR_CONFIG config.

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.serde.RoleBindingMetadataFormatter

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.SpiffeIdPrincipalExtractor

configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

Creates a consumer for the LKC metadata topic (named in the ConfluentConfigs.CDC_LKC_METADATA_TOPIC_CONFIG config.) Adds the instance for the given broker session UUID, specified in KafkaConfig.BrokerSessionUuidProp to the static instance map.

configure(Map<String, ?>) - Method in class io.confluent.kafka.security.authenticator.OAuthKafkaPrincipalBuilder

configure(Map<String, ?>) - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider

configure(Map<String, ?>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

configure(Map<String, ?>) - Method in class io.confluent.kafka.security.ldap.authorizer.LdapAuthorizer

configure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

configure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

configure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

configure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy

configure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy

configure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

configure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustProviderCreator

configure(Map<String, ?>) - Method in class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater

configure(Map<String, ?>) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache

configure(Map<String, ?>) - Method in class io.confluent.security.mtls.DefaultMTlsConnectionManager

configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerServerLoginCallbackHandler

configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler

configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.token.CompositeBearerValidatorCallbackHandler

configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerServerLoginCallbackHandler

configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerValidatorCallbackHandler

configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler

configure(KafkaBasedLog<byte[], byte[]>, String) - Method in class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer

configure(Map<String, String>) - Method in class io.confluent.kafka.link.MultiTenantAclBindingFilterTransformer

configureAccessRuleProviders(Map<String, Object>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

configureMetrics(Metrics) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor

configureServerInfo(ConfluentAuthorizerServerInfo) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

configureServerInfo(ConfluentAuthorizerServerInfo) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

CONFLUENT_IMPERSONATED_BY_CLAIM_NAME - Static variable in class io.confluent.kafka.security.authenticator.OAuthKafkaPrincipalBuilder

ConfluentAuthenticationEvent - Class in io.confluent.kafka.security.audit.event

ConfluentAuthenticationEvent(AuthenticationEvent, Scope) - Constructor for class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

ConfluentServerAuthorizer - Class in io.confluent.kafka.security.authorizer

ConfluentServerAuthorizer() - Constructor for class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

ConfluentTrustManager - Class in io.confluent.kafka.server.plugins.ssl

A trust manager that verifies that the client invalid input: '&' server certificate presented during clientAuth belongs to confluent cloud and then delegates to the defaultTrustManager for general certificate chain validation.

ConfluentTrustManager(Map<String, ?>, X509ExtendedTrustManager) - Constructor for class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

ConfluentTrustManagerFactory - Class in io.confluent.kafka.server.plugins.ssl

ConfluentTrustManagerFactory() - Constructor for class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManagerFactory

ConfluentTrustProvider - Class in io.confluent.kafka.server.plugins.ssl

ConfluentTrustProvider(Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.ssl.ConfluentTrustProvider

ConfluentTrustProviderCreator - Class in io.confluent.kafka.server.plugins.ssl

ConfluentTrustProviderCreator() - Constructor for class io.confluent.kafka.server.plugins.ssl.ConfluentTrustProviderCreator

ConnectionInformationSensors - Class in io.confluent.kafka.multitenant.metrics

A per-connection sensor manager to manage the lifecycles of the connection_info metrics.

ConnectionInformationSensors(Metrics, MultiTenantPrincipal, ClientInformation, String, int) - Constructor for class io.confluent.kafka.multitenant.metrics.ConnectionInformationSensors

ConnectionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics

ConnectionSensorBuilder(Metrics, MultiTenantPrincipal) - Constructor for class io.confluent.kafka.multitenant.metrics.ConnectionSensorBuilder

ConnectionSensors - Class in io.confluent.kafka.multitenant.metrics

ConnectionSensors(Sensor, Sensor) - Constructor for class io.confluent.kafka.multitenant.metrics.ConnectionSensors

CONSUMER_OFFSET_SYNC_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

CONSUMER_OFFSET_SYNC_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

create() - Static method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

create(String) - Static method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

CREATE_ACL_REQUEST_RATE - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer.TenantAuthorizerMetrics

CREATE_ACL_REQUEST_SENSOR - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer.TenantAuthorizerMetrics

createAcls(AuthorizableRequestContext, List<AclBinding>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

createAcls(AuthorizableRequestContext, List<AclBinding>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

createAcls(AuthorizableRequestContext, List<AclBinding>, Optional<String>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

createAcls(AuthorizableRequestContext, List<AclBinding>, Optional<String>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

createAdminClient() - Method in class io.confluent.kafka.multitenant.SslCertificateManager

createAdminClient() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager

createAuthenticationConfig(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.oauth.JwtAuthenticatorConfig

CreateClusterLinkPolicy - Class in io.confluent.kafka.server.plugins.policy

Enforce the policy when creating the cluster links, for example enforcing maximum number of cluster links per tenant.

CreateClusterLinkPolicy() - Constructor for class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy

createSaslServer(String, String, String, Map<String, ?>, CallbackHandler) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer.PlainSaslServerFactory

createSensor(Metrics, String, long) - Method in class io.confluent.kafka.multitenant.metrics.AbstractPartitionSensorCreator

CreateTopicPolicy - Class in io.confluent.kafka.server.plugins.policy

CreateTopicPolicy() - Constructor for class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

crossOrgDeniedSensor - Variable in class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext

ctx() - Method in record class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiSensorsMetricsRequestContext

Returns the value of the ctx record component.

D

data() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

deactivatedClusters() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager

Returns the list of all tenants that are deactivated, but not yet being deleted.

dedicatedLogicalClusterId() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

dedicatedLogicalClusterId() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

DEFAULT - Static variable in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

DEFAULT_ACL_SYNC_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_ACL_SYNC_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_AVAILABILITY_CHECK_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_AVAILABILITY_CHECK_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_CLEANUP_POLICIES_ALLOWED - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_CONSUMER_OFFSET_SYNC_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_CONSUMER_OFFSET_SYNC_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_DATA_POLICY_VALIDATION_MODE_KEY - Static variable in enum class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyValidationMode

DEFAULT_DELETE_RETENTION_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_INTERNAL_LISTENER - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_LOG_CLIENT_IP_ADDRESS - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig

DEFAULT_MAX_COMPACTION_LAG_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

DEFAULT_MAX_COMPACTION_LAG_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_MAX_MESSAGE_BYTES_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_MAX_PARTITIONS_PER_CLUSTER - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_MAX_PARTITIONS_PER_TENANT - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_MAX_REPLICAS_PER_BROKER - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_MAX_TOPICS_PER_CLUSTER - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_MULTI_TENANT_AUDIT_LOGGER_ENABLE_CONFIG - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig

DEFAULT_NUM_PARTITIONS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

DEFAULT_NUM_PARTITIONS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

DEFAULT_REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_RETENTION_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

DEFAULT_RETENTION_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_RETENTION_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

DEFAULT_SASL_LOGIN_CALLBACK_HANDLER_ALLOWED - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_SASL_LOGIN_MODULES_ALLOWED - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_SASL_MECHANISMS_ALLOWED - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_SEGMENT_BYTES_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_SEGMENT_BYTES_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_SEGMENT_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

DEFAULT_SSL_CIPHER_SUITES_ALLOWED - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

DEFAULT_SSL_ENABLED_PROTOCOLS_ALLOWED - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

DEFAULT_TOPIC_CONFIG_SYNC_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DEFAULT_TOPIC_CONFIG_SYNC_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DefaultDataPolicyAuthenticator - Class in io.confluent.kafka.server.plugins.auth

This class is used to authenticate default data policy between various sasl mechanisms.

DefaultDataPolicyAuthenticator(DefaultDataPolicyValidationMode, Collection<String>, boolean, LogicalClusterMetadata, Consumer<String>) - Constructor for class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyAuthenticator

DefaultDataPolicyContext - Class in io.confluent.kafka.server.plugins.auth

DefaultDataPolicyContext.Builder - Class in io.confluent.kafka.server.plugins.auth

DefaultDataPolicyValidationMode - Enum Class in io.confluent.kafka.server.plugins.auth

Enum class that represents different modes of Default Data Policy validation in the authenticator.

DefaultMTlsConnectionManager - Class in io.confluent.security.mtls

The default implementation of MTlsConnectionManager that relies on the broker session.

DefaultMTlsConnectionManager() - Constructor for class io.confluent.security.mtls.DefaultMTlsConnectionManager

DefaultTenantSanitizer - Class in io.confluent.kafka.multitenant.audit

These functions transform various pieces of internal information to remove internal implementation details.

DefaultTenantSanitizer() - Constructor for class io.confluent.kafka.multitenant.audit.DefaultTenantSanitizer

DefaultTenantSanitizer.NotTenantPrefixedException - Exception Class in io.confluent.kafka.multitenant.audit

DefaultUserMetaDataStore - Class in io.confluent.kafka.server.plugins.auth

This class loads user metadata from the topic _confluent-user_metadata.

DefaultUserMetaDataStore(Map<String, ?>, Metrics) - Constructor for class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

DefaultUserMetaDataStore(Map<String, ?>, Metrics, Time) - Constructor for class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

DefaultUserMetaDataStore.State - Enum Class in io.confluent.kafka.server.plugins.auth

DELETE_ACL_REQUEST_RATE - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer.TenantAuthorizerMetrics

DELETE_ACL_REQUEST_SENSOR - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer.TenantAuthorizerMetrics

DELETE_RETENTION_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>, Optional<String>, AclState) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>, Optional<String>, AclState) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

DeleteAclsForMultiTenantPrincipal - Class in io.confluent.kafka.multitenant.tools

DeleteAclsForMultiTenantPrincipal() - Constructor for class io.confluent.kafka.multitenant.tools.DeleteAclsForMultiTenantPrincipal

deletedClusters() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager

Return all logical clusters that were deleted or being deleted Used for testing

deleteTenants() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager

DELIMITER - Static variable in class io.confluent.kafka.multitenant.schema.TenantContext

DeprecatedRequestSensors - Class in io.confluent.kafka.multitenant.metrics

Per-connection manager for deprecated request metric and its quota.

DeprecatedRequestSensors(Metrics, MultiTenantPrincipal, ApiKeys, String, int) - Constructor for class io.confluent.kafka.multitenant.metrics.DeprecatedRequestSensors

DESCRIBE_ACL_REQUEST_RATE - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer.TenantAuthorizerMetrics

DESCRIBE_ACL_REQUEST_SENSOR - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer.TenantAuthorizerMetrics

deserialize(byte[]) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder

deserialize(byte[]) - Method in class io.confluent.kafka.security.authenticator.OAuthKafkaPrincipalBuilder

deserialize(String, byte[]) - Method in class io.confluent.kafka.multitenant.serde.LogicalClusterMetadataRecordDeserializer

deserialize(String, Headers, byte[]) - Method in class io.confluent.kafka.multitenant.serde.LogicalClusterMetadataRecordDeserializer

DEST_METRICS_GROUP - Static variable in class io.confluent.kafka.link.ClusterLinkInterceptor

dispose() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

DOC_MAX_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DOC_MIN_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

DOC_SUFFIX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

E

elasticCkuDefinition(Map<String, String>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

enableDynamicQuota(boolean) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

EnhancedOAuthBearerValidatorCallbackHandler - Class in io.confluent.security.auth.provider.oauth

A CallbackHandler that recognizes OAuthBearerValidatorCallback and OAuthBearerExtensionsValidatorCallback for validating a secured OAuth 2 bearer token issued by Confluent/external OIDC provider, SASL extensions specifying the logical cluster this token is meant for and an identity pool ID to assume if token is from external OIDC provider.

EnhancedOAuthBearerValidatorCallbackHandler() - Constructor for class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler

ensureConnectionAllowed(InetSocketAddress) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor

equals(Object) - Method in record class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiSensorsMetricsRequestContext

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in class io.confluent.kafka.multitenant.serde.EventsMetadataHeader

equals(Object) - Method in class io.confluent.kafka.multitenant.serde.LogicalClusterMetadataRecord

equals(Object) - Method in class io.confluent.kafka.multitenant.SslCertificateSpecification

equals(Object) - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

equals(Object) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials

equals(Object) - Method in class io.confluent.kafka.server.plugins.auth.UserMetaDataKey

evaluateResponse(byte[]) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

EVENTS_METADATA_HEADER_KEY - Static variable in class io.confluent.kafka.multitenant.utils.Utils

eventsMetadata() - Method in class io.confluent.kafka.multitenant.serde.LogicalClusterMetadataRecord

EventsMetadataHeader - Class in io.confluent.kafka.multitenant.serde

EventsMetadataHeader(long, String) - Constructor for class io.confluent.kafka.multitenant.serde.EventsMetadataHeader

ExtendedAccessRuleProvider - Interface in io.confluent.kafka.security.authorizer.acl

EXTERNAL_LISTENER_PREFIX - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

extractPrincipals(String) - Method in class io.confluent.kafka.multitenant.SpiffeIdPrincipalExtractor

extractTenant(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext

extractTenantPrefix(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext

extractType(String) - Method in class io.confluent.kafka.multitenant.CallingResourceIdentityTypeExtractor

F

fail(int, String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

FAILED_TO_START - Enum constant in enum class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer.State

FAILED_TO_START - Enum constant in enum class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore.State

FAILED_TO_START - Enum constant in enum class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler.State

FAILED_TO_START - Enum constant in enum class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater.State

FailedAuthSensors - Class in io.confluent.kafka.multitenant.metrics

FailedAuthSensors(Sensor) - Constructor for class io.confluent.kafka.multitenant.metrics.FailedAuthSensors

FetchApiSensorBuilder - Class in io.confluent.kafka.multitenant.metrics

With Fetch From Follower in cloud, consumers can fetch from the closest replica.

FetchApiSensorBuilder(Metrics, MetricsBuilderContext, ApiKeys, ZoneAlignment, boolean) - Constructor for class io.confluent.kafka.multitenant.metrics.FetchApiSensorBuilder

FetchResponseSensorCreator - Class in io.confluent.kafka.multitenant.metrics

FileBasedLoginModule - Class in io.confluent.kafka.server.plugins.auth

FileBasedLoginModule() - Constructor for class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule

FileBasedPlainSaslAuthenticator - Class in io.confluent.kafka.server.plugins.auth

Authenticate users based on YAML config file which is periodically reloaded

FileBasedPlainSaslAuthenticator() - Constructor for class io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator

FileBasedSaslServerFactory - Class in io.confluent.kafka.server.plugins.auth

FileBasedSaslServerFactory() - Constructor for class io.confluent.kafka.server.plugins.auth.FileBasedSaslServerFactory

FileBasedSaslServerProvider - Class in io.confluent.kafka.server.plugins.auth

findIdentityPools(String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

findIdentityProviderIds(String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

findRule(Set<KafkaPrincipal>, String, Action) - Method in interface io.confluent.kafka.security.authorizer.acl.ExtendedAccessRuleProvider

findRule(Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider

findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in interface io.confluent.kafka.security.authorizer.acl.ExtendedAccessRuleProvider

frequencies(Collection<List<E>>, Function<E, Integer>) - Static method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

fromConfigMap(Map<String, ?>) - Static method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

fromConfigs(Supplier<String>) - Static method in enum class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyValidationMode

fromConfigs(CCloudTrafficType, Supplier<String>) - Static method in enum class io.confluent.kafka.server.plugins.auth.TrafficNetworkIdValidationMode

fromProtobuf(EventsMetadata) - Static method in class io.confluent.kafka.multitenant.serde.EventsMetadataHeader

fromRules(String) - Static method in class io.confluent.kafka.multitenant.SpiffeIdPrincipalExtractor

fromString(String) - Static method in enum class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyValidationMode

fromString(String) - Static method in enum class io.confluent.kafka.server.plugins.auth.SniValidationMode

fromString(String) - Static method in enum class io.confluent.kafka.server.plugins.auth.TrafficNetworkIdValidationMode

fullUpdate(Iterator<Map.Entry<String, Integer>>, Map<Integer, Integer>, Set<String>) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

fullyDeletedClusters() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager

Return all logical clusters that are considered deleted and we won't try to delete again Used for testing

G

generateConfig(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.oauth.JwtAuthenticatorConfig

get(AuthKey) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

get(String, String) - Method in class io.confluent.kafka.server.plugins.auth.AuthAttemptCache

Return the hash for the [username, password] if any

get(List<AppConfigurationEntry>, Map<String, ?>) - Method in interface io.confluent.kafka.server.plugins.auth.SaslServerSupplier

getAcceptedIssuers() - Method in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

getAuthorizationID() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

getBootstrapBrokerForListener(String, Map<String, ?>) - Static method in class io.confluent.common.InterClusterConnection

getContext() - Method in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

Returns a dummy AuthorizableRequestContext which is passed in authorizer::deleteACLs

getInstance(String) - Static method in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

getInstance(String) - Static method in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

getListenerSecurityProtocol(String, Map<String, ?>) - Static method in class io.confluent.common.InterClusterConnection

getMechanismName() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

getMechanismNames(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer.PlainSaslServerFactory

getNegotiatedProperty(String) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

getProvider() - Method in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustProviderCreator

getScope() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

getSessionUuid(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

getTenantWithFlexFanoutEnabled() - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

getText() - Method in enum class io.confluent.kafka.server.plugins.auth.SniValidationMode

H

handle(Callback[]) - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerServerLoginCallbackHandler

handle(Callback[]) - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler

handle(Callback[]) - Method in class io.confluent.kafka.server.plugins.auth.token.CompositeBearerValidatorCallbackHandler

handle(Callback[]) - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerServerLoginCallbackHandler

handle(Callback[]) - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerValidatorCallbackHandler

handle(Callback[]) - Method in class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler

hashCode() - Method in record class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiSensorsMetricsRequestContext

Returns a hash code value for this object.

hashCode() - Method in class io.confluent.kafka.multitenant.serde.EventsMetadataHeader

hashCode() - Method in class io.confluent.kafka.multitenant.serde.LogicalClusterMetadataRecord

hashCode() - Method in class io.confluent.kafka.multitenant.SslCertificateSpecification

hashCode() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

hashCode() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials

hashCode() - Method in class io.confluent.kafka.server.plugins.auth.UserMetaDataKey

hasSslPeerCertificate - Variable in class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext

hasSslPeerCertificate - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials

hasSslPeerCertificate() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer

hasSslPeerCertificate() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

hasSslPeerCertificate(Boolean) - Method in class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext.Builder

hasSslPeerCertificate(Boolean) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials.Builder

hasTenantPrefix(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext

hasTenantPrefix(String, String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext

HotPartitionManager - Class in io.confluent.kafka.multitenant.metrics

Manages the per-partition hot partition metrics derived from the bytes-in and bytes-out metrics on each partition.

HotPartitionManager(Time) - Constructor for class io.confluent.kafka.multitenant.metrics.HotPartitionManager

HotPartitionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics

Builder of HotPartitionSensors to follow the patterns of existing PartitionSensors creation.

HotPartitionSensorBuilder(Metrics, TenantMetrics.TenantMetricsContext) - Constructor for class io.confluent.kafka.multitenant.metrics.HotPartitionSensorBuilder

HotPartitionSensors - Class in io.confluent.kafka.multitenant.metrics

Helper class to create and access the hot partition sensors for a TopicPartition.

HotPartitionSensors(TenantMetrics.TenantMetricsContext, Metrics, HotPartitionSensorBuilder) - Constructor for class io.confluent.kafka.multitenant.metrics.HotPartitionSensors

I

identityPool(String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

identityPools() - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

identityProvider(String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

inactiveClusters() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager

Return all logical clusters that are deactivated

initialize() - Static method in class io.confluent.kafka.server.plugins.auth.FileBasedSaslServerProvider

initialize() - Static method in class io.confluent.kafka.server.plugins.auth.TopicBasedSaslServerProvider

initialize(List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator

initialize(List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator

initialize(List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedPlainSaslAuthenticator

initialize(Subject, CallbackHandler, Map<String, ?>, Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule

initialize(Subject, CallbackHandler, Map<String, ?>, Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule

intConfig(Map<String, ?>, String) - Static method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

INTEGER_ID - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

intercept(AbstractRequest, int) - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

InterClusterConnection - Class in io.confluent.common

InterClusterConnection() - Constructor for class io.confluent.common.InterClusterConnection

INTERNAL_LISTENER_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

invalidate(String, String) - Method in class io.confluent.kafka.server.plugins.auth.AuthAttemptCache

Remove a cache entry, if it exists.

invalidCipherSuiteMessage(Collection<String>, String) - Static method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

invalidEnabledProtocolsMessage(Collection<String>, String) - Static method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

io.confluent.common - package io.confluent.common

io.confluent.common.security.utils - package io.confluent.common.security.utils

io.confluent.kafka.link - package io.confluent.kafka.link

io.confluent.kafka.multitenant - package io.confluent.kafka.multitenant

io.confluent.kafka.multitenant.assignor - package io.confluent.kafka.multitenant.assignor

io.confluent.kafka.multitenant.audit - package io.confluent.kafka.multitenant.audit

io.confluent.kafka.multitenant.authorizer - package io.confluent.kafka.multitenant.authorizer

io.confluent.kafka.multitenant.metrics - package io.confluent.kafka.multitenant.metrics

io.confluent.kafka.multitenant.metrics.utils - package io.confluent.kafka.multitenant.metrics.utils

io.confluent.kafka.multitenant.quota - package io.confluent.kafka.multitenant.quota

io.confluent.kafka.multitenant.schema - package io.confluent.kafka.multitenant.schema

io.confluent.kafka.multitenant.serde - package io.confluent.kafka.multitenant.serde

io.confluent.kafka.multitenant.tools - package io.confluent.kafka.multitenant.tools

io.confluent.kafka.multitenant.utils - package io.confluent.kafka.multitenant.utils

io.confluent.kafka.security.audit.event - package io.confluent.kafka.security.audit.event

io.confluent.kafka.security.authenticator - package io.confluent.kafka.security.authenticator

io.confluent.kafka.security.authorizer - package io.confluent.kafka.security.authorizer

io.confluent.kafka.security.authorizer.acl - package io.confluent.kafka.security.authorizer.acl

io.confluent.kafka.security.ldap.authorizer - package io.confluent.kafka.security.ldap.authorizer

io.confluent.kafka.server.plugins.auth - package io.confluent.kafka.server.plugins.auth

io.confluent.kafka.server.plugins.auth.oauth - package io.confluent.kafka.server.plugins.auth.oauth

io.confluent.kafka.server.plugins.auth.token - package io.confluent.kafka.server.plugins.auth.token

io.confluent.kafka.server.plugins.policy - package io.confluent.kafka.server.plugins.policy

io.confluent.kafka.server.plugins.ssl - package io.confluent.kafka.server.plugins.ssl

io.confluent.kafka.traffic - package io.confluent.kafka.traffic

io.confluent.security.auth.dataplane - package io.confluent.security.auth.dataplane

io.confluent.security.auth.provider.oauth - package io.confluent.security.auth.provider.oauth

io.confluent.security.mtls - package io.confluent.security.mtls

IpConnectionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics

IpConnectionSensorBuilder(Metrics, MultiTenantPrincipal, InetAddress) - Constructor for class io.confluent.kafka.multitenant.metrics.IpConnectionSensorBuilder

IpFailedAuthenticationByIpSensorBuilder - Class in io.confluent.kafka.multitenant.metrics

IpFailedAuthenticationByIpSensorBuilder(Metrics, InetAddress) - Constructor for class io.confluent.kafka.multitenant.metrics.IpFailedAuthenticationByIpSensorBuilder

IpMetricsContext(InetAddress) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.IpMetricsContext

isApiAllowed(ApiKeys) - Static method in class io.confluent.kafka.link.ClusterLinkApis

isApiAllowed(ApiKeys, short, MultiTenantPrincipal) - Method in class io.confluent.kafka.multitenant.schema.MultiTenantApis

Check whether an API is supported.

isAuditLogEnabled() - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

isClusterActive(String) - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager

Returns true if the cluster with the given id is active, false otherwise (a non-existing cluster is considered inactive)

isClusterPrefixForHostnameEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

isComplete() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

isExpired(Metrics, Sensor) - Static method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

isFetchFromFollowerEnabled() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

isFetchFromFollowerEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

isFetchFromFollowerRequireLeaderEpochEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

isMasterWriter() - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

isNewTopic() - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo

isPpv2EndpointSchemeEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

isPpv2EndPointSchemeEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

isPpv2EndpointSchemeMapBrokerToGatewayZoneEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

isPpv2EndpointSchemeMapBrokerToGatewayZoneEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

isSchemaValidationEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

isSuperUser(MultiTenantPrincipal, Action, boolean, boolean, boolean) - Static method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

isSuperUser(KafkaPrincipal, Scope) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

isSuperUser(KafkaPrincipal, Scope) - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider

isSupportedFFFClient(FetchRequest, boolean) - Static method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

The IS_SUPPORTED_FFF_CLIENT tag is set to false if client tries to use FetchFromFollower from KIP-392, but hasn't added CurrentLeaderEpoch to the FetchRequest that is introduced in KIP-320.

isTenantPrefixed(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext

isTransformRequired(ResourceType) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext

isUp() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

Returns true if cache is loaded and listening for metadata, otherwise returns false.

isUp() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

isVersionDeprecated() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

J

jsonWebKeySet(String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

jsonWebKeySets() - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

JWT_AUTHENTICATOR_CONFIG_URL - Static variable in class io.confluent.kafka.server.plugins.auth.oauth.JwtAuthenticatorConfig

JWT_AUTHENTICATOR_CONFIG_URL_DOC - Static variable in class io.confluent.kafka.server.plugins.auth.oauth.JwtAuthenticatorConfig

JwtAuthenticatorConfig - Class in io.confluent.kafka.server.plugins.auth.oauth

JwtIssuerAuthCache - Class in io.confluent.security.auth.dataplane

Fetches Signature Verification key information from AuthCache according to issuer information from the token claim.

JwtIssuerAuthCache.Builder - Class in io.confluent.security.auth.dataplane

K

kafkaLogicalClusterIds() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

kafkaLogicalClusterIds() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

KafkaLogicalClusterMetadataLoader - Class in io.confluent.kafka.multitenant

This class loads the LogicalClusterMetadata from the topic configured by ConfluentConfigs.CDC_LKC_METADATA_TOPIC_CONFIG.

KafkaLogicalClusterMetadataLoader(Map<String, ?>, Metrics, Time) - Constructor for class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadataLoader

The constructor used during Kafka startup.

KafkaLogicalClusterMetadataLoaderMetrics - Class in io.confluent.kafka.multitenant

KafkaLogicalClusterMetadataLoaderMetrics(Metrics) - Constructor for class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadataLoaderMetrics

KafkaVerificationKeyResolver - Class in io.confluent.kafka.server.plugins.auth.oauth

KafkaVerificationKeyResolver(String, String, SecurityContext) - Constructor for class io.confluent.kafka.server.plugins.auth.oauth.KafkaVerificationKeyResolver

keyResolver(Collection<Constraint>, SecurityContext) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache

Returns Signature Verification Key identified by AuthCache

L

LdapAuthorizer - Class in io.confluent.kafka.security.ldap.authorizer

LdapAuthorizer() - Constructor for class io.confluent.kafka.security.ldap.authorizer.LdapAuthorizer

linkAdded(Uuid, Optional<String>, String) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy

LinkContext - Class in io.confluent.kafka.link

LinkContext(String, String, String, Boolean) - Constructor for class io.confluent.kafka.link.LinkContext

linkDeleted(Uuid) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy

linkName() - Method in class io.confluent.kafka.link.LinkContext

links() - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy

load(String, long, long) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsLoader

loadAclSnapshot(Map<Uuid, ConfluentStandardAcl>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

loadAclSnapshot(Map<Uuid, ConfluentStandardAcl>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

loadKeyPair(InputStream) - Static method in class io.confluent.common.security.utils.PemUtils

loadPublicKey(InputStream) - Static method in class io.confluent.common.security.utils.PemUtils

log - Static variable in class io.confluent.kafka.multitenant.SpiffeIdPrincipalExtractor

LOG_CLIENT_IP_ADDRESS - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig

LOG_CLIENT_IP_ADDRESS_DOC - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig

logicalClusterId - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials

logicalClusterId(String) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials.Builder

logicalClusterIds() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

logicalClusterIds() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

logicalClusterIdsIncludingStale() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

logicalClusterMetadata() - Method in class io.confluent.kafka.multitenant.serde.LogicalClusterMetadataRecord

LogicalClusterMetadataRecord - Class in io.confluent.kafka.multitenant.serde

LogicalClusterMetadataRecord(EventsMetadataHeader, LogicalClusterMetadata) - Constructor for class io.confluent.kafka.multitenant.serde.LogicalClusterMetadataRecord

LogicalClusterMetadataRecordDeserializer - Class in io.confluent.kafka.multitenant.serde

LogicalClusterMetadataRecordDeserializer() - Constructor for class io.confluent.kafka.multitenant.serde.LogicalClusterMetadataRecordDeserializer

login() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule

login() - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule

logout() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule

logout() - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule

M

main(String[]) - Static method in class io.confluent.kafka.multitenant.tools.DeleteAclsForMultiTenantPrincipal

main(String[]) - Static method in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

main(String[]) - Static method in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

map(String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

masterWriterId() - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

masterWriterUrl(String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

MAX_ACLS_PER_TENANT_PROP - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

MAX_COMPACTION_LAG_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

MAX_COMPACTION_LAG_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

MAX_DEST_LINKS_PER_TENANT_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

MAX_MESSAGE_BYTES_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

MAX_PARTITIONS_PER_CLUSTER_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

MAX_PARTITIONS_PER_TENANT_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

MAX_REPLICAS_PER_BROKER_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

MAX_SOURCE_LINKS_PER_TENANT_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

MAX_TOPICS_PER_CLUSTER_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

maybeBuildAssignor(Optional<KafkaPrincipal>, PartitionPlacementStrategy) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder

Builds a #TopicReplicaAssignor to be used for replica assignment.

maybeUpdateElasticCkuDefinition(String, Map<ElasticCkuDefinitionUtils.ElasticCkuDefinitionKey, Integer>) - Static method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

maybeUpdateFlexibleFanoutEnabled(String, boolean) - Static method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

mayDeny() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

mayDeny() - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider

mayRecordHotPartitionIn(Metrics, TenantMetrics.TenantMetricsContext, TopicPartition, long) - Method in class io.confluent.kafka.multitenant.metrics.HotPartitionManager

Records the existence of hot partition ingress-wise for the given partition.

mayRecordHotPartitionOut(Metrics, TenantMetrics.MetricsRequestContext, TopicPartition, long) - Method in class io.confluent.kafka.multitenant.metrics.HotPartitionManager

Records the existence of hot partition egress-wise for the given partition.

metadata(String) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

METRIC_GROUP - Static variable in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder

METRIC_GROUP - Static variable in class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler

metrics() - Method in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

metrics() - Method in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

METRICS_GROUP - Static variable in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

METRICS_GROUP - Static variable in class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater

MetricSampler - Interface in io.confluent.kafka.multitenant.metrics.utils

An interface to implement sampled recording of metrics.

metricsGroup() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeysVersionContext

metricsGroup() - Method in record class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiSensorsMetricsRequestContext

metricsGroup() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.IpMetricsContext

metricsGroup() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantLevelMetricsContext

metricsGroup() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext

metricsRequestContext() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

MetricsRequestContext(MultiTenantPrincipal, String, ApiKeys) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

MetricsRequestContext(MultiTenantPrincipal, String, ApiKeys, short) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

MetricsRequestContext(MultiTenantPrincipal, String, ApiKeys, short, boolean, String) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeyMetricsContext

metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeysVersionContext

metricTags() - Method in record class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiSensorsMetricsRequestContext

metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.IpMetricsContext

metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantConnectionInformationMetricsContext

metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantIpMetricsContext

metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantLevelMetricsContext

metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext

metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.ZoneDataMetricsRequestContext

metricTags(String, String) - Static method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeyMetricsContext

MIN_ISR - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

MIN_REMOTE_CLIENT_CERT_EXPIRY_MS - Static variable in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

MockBasicAuthStore - Class in io.confluent.kafka.server.plugins.auth.oauth

MockBasicAuthStore(String) - Constructor for class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

MockTrustCache - Class in io.confluent.kafka.server.plugins.auth.oauth

MockTrustCache() - Constructor for class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

MULTI_TENANT_AUDIT_LOGGER_ENABLE_CONFIG - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig

MULTI_TENANT_AUDIT_LOGGER_ENABLE_CONFIG_DOC - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig

MULTITENANT_MAX_PARTITIONS_PER_REQUEST_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

MULTITENANT_MAX_PARTITIONS_PER_REQUEST_DEFAULT - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

MULTITENANT_MAX_PARTITIONS_PER_REQUEST_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

MULTITENANT_SCHEMA_VALIDATION_ENABLED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

MULTITENANT_SCHEMA_VALIDATION_ENABLED_DEFAULT - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

MultiTenantAclBindingFilterTransformer - Class in io.confluent.kafka.link

MultiTenantAclBindingFilterTransformer() - Constructor for class io.confluent.kafka.link.MultiTenantAclBindingFilterTransformer

MultiTenantApis - Class in io.confluent.kafka.multitenant.schema

MultiTenantApis(boolean) - Constructor for class io.confluent.kafka.multitenant.schema.MultiTenantApis

MultiTenantAuditLogConfig - Class in io.confluent.kafka.multitenant.authorizer

MultiTenantAuditLogConfig(Map<String, ?>) - Constructor for class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig

MultiTenantAuthorizer - Class in io.confluent.kafka.multitenant.authorizer

MultiTenantAuthorizer() - Constructor for class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

MultiTenantAuthorizer.TenantAuthorizerMetrics - Class in io.confluent.kafka.multitenant.authorizer

MultiTenantConfigRestrictions - Class in io.confluent.kafka.multitenant

MultiTenantConfigRestrictions() - Constructor for class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

MultiTenantInterceptor - Class in io.confluent.kafka.multitenant

MultiTenantInterceptor() - Constructor for class io.confluent.kafka.multitenant.MultiTenantInterceptor

MultiTenantInterceptor(Time) - Constructor for class io.confluent.kafka.multitenant.MultiTenantInterceptor

MultiTenantInterceptorConfig - Class in io.confluent.kafka.multitenant

MultiTenantInterceptorConfig(boolean, boolean, boolean, boolean, String, String, String, Map<String, String>, String, boolean, boolean, boolean, BrokerFqdnBuilder, boolean) - Constructor for class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

multiTenantPrincipal(String, MultiTenantSaslConfigEntry) - Static method in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator

MultiTenantPrincipalBuilder - Class in io.confluent.kafka.multitenant

Principal builder that returns a MultiTenantPrincipal if tenant id is available.

MultiTenantPrincipalBuilder() - Constructor for class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder

MultiTenantPrincipalBuilderUtils - Class in io.confluent.kafka.multitenant.utils

MultiTenantPrincipalBuilderUtils() - Constructor for class io.confluent.kafka.multitenant.utils.MultiTenantPrincipalBuilderUtils

MultiTenantRequestContext - Class in io.confluent.kafka.multitenant

MultiTenantRequestContext(RequestHeader, String, long, InetAddress, Optional<Integer>, MultiTenantPrincipal, ListenerName, SecurityProtocol, ClientInformation, PathAwareSniHostName, Time, Metrics, TenantMetrics, HotPartitionManager, MultiTenantInterceptorConfig, Optional<ClusterLinkSourceMetrics>, boolean, Optional<KafkaPrincipalSerde>, AuthenticationContext, ProduceConsumeAuditLogTracker, boolean, BrokerFqdnBuilder.FQDNPropertiesFromPPV2, String, boolean) - Constructor for class io.confluent.kafka.multitenant.MultiTenantRequestContext

MultiTenantRequestContext(RequestHeader, String, long, InetAddress, Optional<Integer>, MultiTenantPrincipal, ListenerName, SecurityProtocol, ClientInformation, PathAwareSniHostName, Time, Metrics, TenantMetrics, HotPartitionManager, MultiTenantInterceptorConfig, Optional<ClusterLinkSourceMetrics>, boolean, Optional<KafkaPrincipalSerde>, AuthenticationContext, ProduceConsumeAuditLogTracker, boolean, BrokerFqdnBuilder.FQDNPropertiesFromPPV2, String, boolean, ConfluentMetricsContextProvider, Optional<ClientRequestRateQuotaManager>) - Constructor for class io.confluent.kafka.multitenant.MultiTenantRequestContext

MultiTenantSaslSecretsLoader - Class in io.confluent.kafka.server.plugins.auth

This class loads and caches SASL secrets from a JSON file stored on the local filesystem.

MultiTenantSaslSecretsLoader(int) - Constructor for class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsLoader

MultiTenantSaslSecretsStore - Class in io.confluent.kafka.server.plugins.auth

MultiTenantSaslSecretsStore(Map<String, Object>, Metrics) - Constructor for class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore

MultiTenantSaslServer - Interface in io.confluent.kafka.multitenant

N

name() - Method in class io.confluent.kafka.multitenant.metrics.FetchResponseSensorCreator

name() - Method in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

name() - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

name() - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache

name(String) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder

networkId - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials

networkId() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer

networkId() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

networkId(String) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials.Builder

NetworkLinkTrustManager - Class in io.confluent.kafka.server.plugins.ssl

NetworkLinkTrustManager(Map<String, ?>, X509ExtendedTrustManager) - Constructor for class io.confluent.kafka.server.plugins.ssl.NetworkLinkTrustManager

NetworkLinkTrustManagerFactory - Class in io.confluent.kafka.server.plugins.ssl

NetworkLinkTrustManagerFactory() - Constructor for class io.confluent.kafka.server.plugins.ssl.NetworkLinkTrustManagerFactory

networkType - Variable in class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext

networkType - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials

networkType() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

networkType() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer

networkType() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

networkType(SaslInternalConfigs.NetworkType) - Method in class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext.Builder

networkType(SaslInternalConfigs.NetworkType) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials.Builder

newContext(BrokerInterceptor.RequestContextOptions) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor

newInstance(Map<String, ?>) - Static method in class io.confluent.kafka.server.plugins.auth.oauth.JwtAuthenticatorConfig

NONE - Enum constant in enum class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyValidationMode

NONE - Enum constant in enum class io.confluent.kafka.server.plugins.auth.TrafficNetworkIdValidationMode

NOT_ENABLED - Enum constant in enum class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer.State

NOT_ENABLED - Enum constant in enum class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater.State

NOT_READY - Enum constant in enum class io.confluent.kafka.multitenant.PhysicalClusterMetadata.State

NOT_STARTED - Enum constant in enum class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer.State

NOT_STARTED - Enum constant in enum class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore.State

NOT_STARTED - Enum constant in enum class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler.State

NOT_STARTED - Enum constant in enum class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater.State

NotTenantPrefixedException(String) - Constructor for exception class io.confluent.kafka.multitenant.audit.DefaultTenantSanitizer.NotTenantPrefixedException

NUM_PARTITIONS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

NUM_PARTITIONS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

numOfMapping() - Method in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

O

OAuthBearerServerLoginCallbackHandler - Class in io.confluent.kafka.server.plugins.auth.oauth

A CallbackHandler for the OAuthLoginModule of a Kafka Broker.

OAuthBearerServerLoginCallbackHandler() - Constructor for class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerServerLoginCallbackHandler

OAuthBearerValidatorCallbackHandler - Class in io.confluent.kafka.server.plugins.auth.oauth

A CallbackHandler that recognizes OAuthBearerValidatorCallback and OAuthBearerExtensionsValidatorCallback for validating a secured OAuth 2 bearer token issued by Confluent and SASL extensions specifying the logical cluster this token is meant for.

OAuthBearerValidatorCallbackHandler() - Constructor for class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler

oauthClaim(OAuthBearerJwsToken, String) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder

OAuthKafkaPrincipalBuilder - Class in io.confluent.kafka.security.authenticator

This class is used to build a KafkaPrincipal which provides support for SASL/OAUTHBEARER authentication.

OAuthKafkaPrincipalBuilder() - Constructor for class io.confluent.kafka.security.authenticator.OAuthKafkaPrincipalBuilder

onApiVersionsRequest(ClientInformation, String, KafkaPrincipal, Metrics) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor

onAuthenticatedConnection(String, InetAddress, KafkaPrincipal, Metrics, ChannelMetadataRegistry) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor

onAuthenticatedDisconnection(String, InetAddress, KafkaPrincipal, Metrics) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor

onControllerChange(LeaderAndEpoch) - Method in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

onFailedAuthentication(String, InetAddress, Metrics) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor

onMetadataUpdate(Map<String, ? extends LogicalClusterMetadata>) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

onMetadataUpdate(MetadataDelta, MetadataImage, LoaderManifest) - Method in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

operation(AclOperation) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper

OPTIONAL_VALIDATION - Enum constant in enum class io.confluent.kafka.server.plugins.auth.SniValidationMode

organizationId - Variable in class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext

organizationId - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials

organizationId() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer

organizationId() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

organizationId(String) - Method in class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyContext.Builder

organizationId(String) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials.Builder

orgResourceId() - Method in class io.confluent.kafka.server.plugins.auth.UserMetaDataKey

P

parentQuotaMetricTags(ClientQuotaType, Map<String, String>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

parsedResponse(AbstractResponse, short) - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

parseRequest(Readable) - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

parseResponse(ByteBuffer, RequestHeader, long, long) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor

partialUpdate(String, int, int, Map<Integer, List<Integer>>, Map<Integer, List<Integer>>, boolean, boolean) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

PartitionMetricUtils - Class in io.confluent.kafka.multitenant.metrics.utils

PartitionMetricUtils() - Constructor for class io.confluent.kafka.multitenant.metrics.utils.PartitionMetricUtils

PartitionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics

PartitionSensorBuilder(Metrics, TenantMetrics.MetricsRequestContext) - Constructor for class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder

PartitionSensors - Class in io.confluent.kafka.multitenant.metrics

PartitionSensors(TenantMetrics.MetricsRequestContext, Metrics, PartitionSensorBuilder) - Constructor for class io.confluent.kafka.multitenant.metrics.PartitionSensors

password - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials

PemUtils - Class in io.confluent.common.security.utils

PemUtils() - Constructor for class io.confluent.common.security.utils.PemUtils

permissionType(AclPermissionType) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper

PhysicalClusterMetadata - Class in io.confluent.kafka.multitenant

This holds metadata passed from CCloud related to this physical cluster

PhysicalClusterMetadata(Metrics) - Constructor for class io.confluent.kafka.multitenant.PhysicalClusterMetadata

PhysicalClusterMetadata(Metrics, Time) - Constructor for class io.confluent.kafka.multitenant.PhysicalClusterMetadata

PhysicalClusterMetadata.State - Enum Class in io.confluent.kafka.multitenant

PLAIN_MECHANISM - Static variable in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

PlainSaslAuthenticator - Class in io.confluent.kafka.server.plugins.auth

PlainSaslAuthenticator(AuthAttemptCache, AuthAttemptCache) - Constructor for class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator

PlainSaslCredentials - Class in io.confluent.kafka.server.plugins.auth

PlainSaslCredentials.Builder - Class in io.confluent.kafka.server.plugins.auth

PlainSaslServer - Class in io.confluent.kafka.server.plugins.auth

SaslServer implementation for SASL/PLAIN with an authenticator provided through the constructor.

PlainSaslServer(List<AppConfigurationEntry>, SaslAuthenticator, Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.auth.PlainSaslServer

PlainSaslServer.PlainSaslServerFactory - Class in io.confluent.kafka.server.plugins.auth

PlainSaslServerFactory(SaslServerSupplier) - Constructor for class io.confluent.kafka.server.plugins.auth.PlainSaslServer.PlainSaslServerFactory

PolicyUtils - Class in io.confluent.kafka.server.plugins.policy

prefix - Variable in class io.confluent.kafka.multitenant.schema.TenantContext

prefix() - Method in class io.confluent.kafka.multitenant.schema.TenantContext

prefixedWildcard() - Method in class io.confluent.kafka.multitenant.schema.TenantContext

prefixSizeInBytes() - Method in class io.confluent.kafka.multitenant.schema.TenantContext

prependExternalListenerToConfigName(String) - Static method in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

Return an empty Optional if `configName` is not an updatable listener config name, otherwise return the config name with `EXTERNAL_LISTENER_PREFIX` prepended within the Optional.

principal - Variable in class io.confluent.kafka.multitenant.schema.TenantContext

principal() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext

principal() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

PRINCIPAL_RESOURCE_ID - Static variable in class io.confluent.kafka.multitenant.audit.DefaultTenantSanitizer

principalExtractionRulesCount() - Method in class io.confluent.kafka.multitenant.SpiffeIdPrincipalExtractor

PROVIDER_NAME - Static variable in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustProvider

providerName() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

providerName() - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider

put(AuthKey, AuthValue) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

put(String, String, String) - Method in class io.confluent.kafka.server.plugins.auth.AuthAttemptCache

Cache an authorisation.

Q

quotaLimit(ClientQuotaType, Map<String, String>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

quotaMetricTags(ClientQuotaType, KafkaPrincipal, String) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

quotaMetricTagsFromTopic(ClientQuotaType, String) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

quotaResetRequired(ClientQuotaType) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

R

rackForBroker(int) - Method in interface io.confluent.kafka.multitenant.assignor.RackMetadata

RackMetadata - Interface in io.confluent.kafka.multitenant.assignor

read(EntityType, String) - Method in class io.confluent.kafka.link.LinkContext

read(EntityType, String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext

read(EntityType, Message) - Method in class io.confluent.kafka.link.LinkContext

read(EntityType, Message) - Method in class io.confluent.kafka.multitenant.schema.TenantContext

reconfigurableConfigs() - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

reconfigurableConfigs() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

reconfigurableConfigs() - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

reconfigurableConfigs() - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

reconfigurableConfigs() - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy

reconfigurableConfigs() - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy

reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

recordApiKeyMaxVersion(Metrics, ApiKeys, int) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

recordAuthenticatedConnection() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionInformationSensors

Gets or Creates a Sensor and record the new authenticated connection to emit the connection information as the tags of a KafkaMetric.

recordAuthenticatedConnection() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensors

recordAuthenticatedConnection(Metrics, MultiTenantPrincipal, InetAddress) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

recordAuthenticatedDisconnection() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionInformationSensors

Reduces the number of authenticated connection sharing the same connection information by one if the corresponding metric exists.

recordAuthenticatedDisconnection() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensors

recordAuthenticatedDisconnection() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

recordAuthorizationDeniedMetric(AuthorizableRequestContext, List<AuthorizationResult>, List<Action>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer.TenantAuthorizerMetrics

recordClientInformation(Metrics, MultiTenantPrincipal, ClientInformation, String, int) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

recordDeprecatedRequest() - Method in class io.confluent.kafka.multitenant.metrics.DeprecatedRequestSensors

Record a received deprecated request.

recordFailedAuthentication() - Method in class io.confluent.kafka.multitenant.metrics.FailedAuthSensors

recordFailedAuthentication(Metrics, InetAddress) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

recordHotPartitionIn(TopicPartition, long) - Method in class io.confluent.kafka.multitenant.metrics.HotPartitionSensors

Marks the given partition as hot ingress-wise at the given timestamp.

recordHotPartitionOut(TopicPartition, long) - Method in class io.confluent.kafka.multitenant.metrics.HotPartitionSensors

Marks the given partition as hot egress-wise at the given timestamp.

recordMaxVersion(int) - Method in class io.confluent.kafka.multitenant.metrics.ApiKeysVersionSensors

recordPartitionStatsIn(Metrics, TenantMetrics.MetricsRequestContext, TopicPartition, int, int, long) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

recordPartitionStatsOut(Metrics, TenantMetrics.MetricsRequestContext, TopicPartition, int, int, long) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

recordRequest(Metrics, TenantMetrics.MetricsRequestContext, long, long) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

recordResponse(Metrics, TenantMetrics.MetricsRequestContext, long, long, Map<Errors, Integer>, long) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

recordStartupLoadTime(long) - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadataLoaderMetrics

recordStatsIn(TopicPartition, long, long, long) - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensors

recordStatsOut(TopicPartition, long, long, long) - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensors

refreshTokenInfo(String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

registerMetrics(Metrics) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

registerTenantCallback(Function<String, Boolean>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

Registers tenant callback function to be invoked whenever a new tenant is added.

registerTenantDeactivatedCallback(Function<String, Boolean>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

Registers tenant callback function to be invoked whenever a tenant is deactivated (but may not be deleted yet, TenantLifeCycleManager is responsible for the actual deletion of resources).

registerTenantMetadataUpdateCallback(Function<String, Boolean>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

Registers tenant callback function to be invoked whenever a tenant is updated.

remove(AuthKey) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

removeAllTenantPrefixes(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext

removePrefix(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext

removeQuota(ClientQuotaType, ClientQuotaEntity) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

removeTenantPrefix(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext

removeTenantPrefix(TopicPartition) - Method in class io.confluent.kafka.multitenant.schema.TenantContext

removeTenantPrefixNullable(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext

removeUserPrefix(String) - Static method in class io.confluent.kafka.multitenant.tools.DeleteAclsForMultiTenantPrincipal

REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

REPLICATION_FACTOR_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

replicationFactor() - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo

REQUESTED_SAME_ORG - Enum constant in enum class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyValidationMode

resolveKey(JsonWebSignature, List<JsonWebStructure>) - Method in class io.confluent.kafka.server.plugins.auth.oauth.KafkaVerificationKeyResolver

Query TrustCache for public key corresponding to .

RESOURCE_ID - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer

resourcePattern(ResourcePattern) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper

resourceType(ResourceType) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper

restrictTopicConfigs(Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

RETENTION_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

RETENTION_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

RETENTION_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

RoleBindingMetadataFormatter - Class in io.confluent.kafka.multitenant.serde

RoleBindingMetadataFormatter() - Constructor for class io.confluent.kafka.multitenant.serde.RoleBindingMetadataFormatter

RUNNING - Enum constant in enum class io.confluent.kafka.multitenant.PhysicalClusterMetadata.State

RUNNING - Enum constant in enum class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer.State

RUNNING - Enum constant in enum class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore.State

RUNNING - Enum constant in enum class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler.State

RUNNING - Enum constant in enum class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater.State

S

SASL_LOGIN_CALLBACK_HANDLER_ALLOWED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

SASL_LOGIN_MODULES_ALLOWED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

SASL_MECHANISMS_ALLOWED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

SaslServerSupplier - Interface in io.confluent.kafka.server.plugins.auth

sbcApisEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

Denotes whether the SBC APIs (like ConfluentAdmin.removeBrokers(List)) will be allowed through the interceptor

SEGMENT_BYTES_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

SEGMENT_BYTES_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

SEGMENT_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeyMetricsContext

sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeysVersionContext

sensorSuffix() - Method in record class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiSensorsMetricsRequestContext

sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.IpMetricsContext

sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantConnectionInformationMetricsContext

sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantIpMetricsContext

sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantLevelMetricsContext

sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext

sequenceId() - Method in class io.confluent.kafka.multitenant.serde.EventsMetadataHeader

serialize(KafkaPrincipal) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder

serialize(KafkaPrincipal) - Method in class io.confluent.kafka.security.authenticator.OAuthKafkaPrincipalBuilder

sessionUuid() - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache

sessionUuid(String) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder

setAclMutator(AclMutator) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

setAdminSupplierAndCreateClient(Function<String, Admin>) - Method in class io.confluent.kafka.multitenant.SslCertificateManager

setAdminSupplierAndCreateClient(Function<String, Admin>) - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager

setData(Map<String, Object>) - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

setFetchFromFollowerTags(Metrics, MetricsBuilderContext, ApiKeys, ZoneAlignment, boolean) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics

setRequestRateQuotaManager(Object) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor

setTenantContext(String) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor

setTenantMaxDestLinks(Optional<String>, Optional<Integer>) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy

setTenantMaxSourceLinks(Optional<String>, Optional<Integer>) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy

shouldAppendSubdomainToHostname() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

shouldIntercept() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

shouldSample() - Method in interface io.confluent.kafka.multitenant.metrics.utils.MetricSampler

shouldSample() - Method in class io.confluent.kafka.multitenant.metrics.utils.TimeIntervalMetricSampler

SHUTTING_DOWN - Enum constant in enum class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore.State

sizeOfRemovedPrefixes(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext

SNI_HOST_NAME_VALIDATION_MODE_KEY - Static variable in enum class io.confluent.kafka.server.plugins.auth.SniValidationMode

sniHostName - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials

sniHostName(PathAwareSniHostName) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials.Builder

sniHostNameMatches(String, Optional<String>, Optional<PathAwareSniHostName>) - Method in enum class io.confluent.kafka.server.plugins.auth.SniValidationMode

Validate if the supplied cluster Id matches with the ground truth.

SniValidationMode - Enum Class in io.confluent.kafka.server.plugins.auth

Enum class that represents different mode of SNI host name validation in the authenticator.

SOURCE_METRICS_GROUP - Static variable in class io.confluent.kafka.link.ClusterLinkInterceptor

SpiffeIdPrincipalExtractor - Class in io.confluent.kafka.multitenant

The SpiffeIdPrincipalExtractor is a component designed to extract Principals from SPIFFE IDs.

SpiffeIdPrincipalExtractor() - Constructor for class io.confluent.kafka.multitenant.SpiffeIdPrincipalExtractor

SpiffeIdPrincipalExtractor(String) - Constructor for class io.confluent.kafka.multitenant.SpiffeIdPrincipalExtractor

SSL_CIPHER_SUITES_ALLOWED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

SSL_ENABLED_PROTOCOLS_ALLOWED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

sslCertificateManager - Variable in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

sslCertificateManager - Variable in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

SslCertificateManager - Class in io.confluent.kafka.multitenant

SslCertificateSpecification - Class in io.confluent.kafka.multitenant

Represents specifications for ssl certificates - pem and pkcs

StandardAclProvider - Class in io.confluent.kafka.security.authorizer.acl

Provider implementation which derives access rules from StandardAuthorizer, which is the default authorizer for KRaft and stores rules in the __cluster_metadata topic.

StandardAclProvider() - Constructor for class io.confluent.kafka.security.authorizer.acl.StandardAclProvider

start() - Method in class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer

start(Boolean) - Method in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

start(Collection<Endpoint>) - Method in class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater

start(Collection<Endpoint>, List<MultiTenantMetadataPublisher>) - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadataLoader

start(Map<String, Object>, Collection<Endpoint>) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

start(Map<String, Object>, Collection<Endpoint>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

start(AuthorizerServerInfo) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

start(AuthorizerServerInfo) - Method in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

start(ConfluentAuthorizerServerInfo) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

start(ConfluentAuthorizerServerInfo) - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider

startClients(Function<String, Admin>) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

startClients(Function<String, Admin>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

STARTING - Enum constant in enum class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer.State

STARTING - Enum constant in enum class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore.State

STARTING - Enum constant in enum class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler.State

STARTING - Enum constant in enum class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater.State

startReader() - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

startService(Collection<URL>) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

status() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

status(int) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache

STRICT - Enum constant in enum class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyValidationMode

STRICT - Enum constant in enum class io.confluent.kafka.server.plugins.auth.SniValidationMode

STRICT - Enum constant in enum class io.confluent.kafka.server.plugins.auth.TrafficNetworkIdValidationMode

stripExternalListenerPrefixFromConfigName(String) - Static method in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

Return an empty Optional if `configName` is not an updatable external listener config name, otherwise return the config name with `EXTERNAL_LISTENER_PREFIX` stripped within the Optional.

subdomainSeparatorMap() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

subdomainSeparatorVariable() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

T

TenantAclProvider - Class in io.confluent.kafka.multitenant.authorizer

Multi-tenant authorizer that supports: ACLs with TenantUser:clusterId_userId as principal ACLs with TenantUser*:clusterId_ as wildcard prefixed principal ACLs with User:* as wildcard principal (e.g.

TenantAclProvider() - Constructor for class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

tenantAuditEvent(AuditEvent) - Method in class io.confluent.kafka.multitenant.audit.DefaultTenantSanitizer

tenantAuditEvent(AuditEvent) - Method in interface io.confluent.kafka.multitenant.audit.TenantSanitizer

tenantAuditEvent(AuditEvent, String) - Method in class io.confluent.kafka.multitenant.audit.DefaultTenantSanitizer

tenantAuditEvent(AuditEvent, String) - Method in interface io.confluent.kafka.multitenant.audit.TenantSanitizer

TenantClientQuotaConsumer - Class in io.confluent.kafka.multitenant.quota

TenantClientQuotaConsumer(Map<String, ?>, Metrics) - Constructor for class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer

TenantClientQuotaConsumer(Map<String, ?>, Metrics, Time) - Constructor for class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer

Creates a new TenantClientQuotaConsumer, that reads user quotas from the sync pipeline topic and applies them.

TenantClientQuotaConsumer.State - Enum Class in io.confluent.kafka.multitenant.quota

TenantClientQuotaFormatter - Class in io.confluent.kafka.multitenant.quota

TenantClientQuotaFormatter() - Constructor for class io.confluent.kafka.multitenant.quota.TenantClientQuotaFormatter

TenantConnectionInformationMetricsContext(MultiTenantPrincipal, ClientInformation, String) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantConnectionInformationMetricsContext

TenantContext - Class in io.confluent.kafka.multitenant.schema

This class contains the core logic to transform Kafka requests and responses so that topics/groups/etc have appropriate tenant prefixes.

TenantContext(MultiTenantPrincipal) - Constructor for class io.confluent.kafka.multitenant.schema.TenantContext

TenantIpMetricsContext(MultiTenantPrincipal, InetAddress) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantIpMetricsContext

TenantLevelMetricsContext(MultiTenantPrincipal) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantLevelMetricsContext

tenantLifecycleManager - Variable in class io.confluent.kafka.multitenant.PhysicalClusterMetadata

tenantLifecycleManager - Variable in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

TenantLifecycleManager - Class in io.confluent.kafka.multitenant

TenantLifecycleManager(Map<String, ?>, Time) - Constructor for class io.confluent.kafka.multitenant.TenantLifecycleManager

tenantMetadata() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer

tenantMetadata() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

TenantMetrics - Class in io.confluent.kafka.multitenant.metrics

TenantMetrics() - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics

TenantMetrics.ApiKeyMetricsContext - Class in io.confluent.kafka.multitenant.metrics

TenantMetrics.ApiKeysVersionContext - Class in io.confluent.kafka.multitenant.metrics

TenantMetrics.ApiSensorsMetricsRequestContext - Record Class in io.confluent.kafka.multitenant.metrics

TenantMetrics.IpMetricsContext - Class in io.confluent.kafka.multitenant.metrics

TenantMetrics.MetricsRequestContext - Class in io.confluent.kafka.multitenant.metrics

TenantMetrics.TenantConnectionInformationMetricsContext - Class in io.confluent.kafka.multitenant.metrics

TenantMetrics.TenantIpMetricsContext - Class in io.confluent.kafka.multitenant.metrics

TenantMetrics.TenantLevelMetricsContext - Class in io.confluent.kafka.multitenant.metrics

TenantMetrics.TenantMetricsContext - Class in io.confluent.kafka.multitenant.metrics

TenantMetrics.ZoneDataMetricsRequestContext - Class in io.confluent.kafka.multitenant.metrics

Starting first with K2's initial Freight offering and XENI, zone alignment between the client, the Confluent-provided gateway into Confluent Cloud, and the serving broker is almost always possible, so it's important to track how exactly the zones of these three layers align.

TenantMetricsContext(MultiTenantPrincipal) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext

TenantPartitionAssignor - Class in io.confluent.kafka.multitenant.assignor

Tenant partition assignor that attempts to balance tenant partitions across available brokers to ensure that quotas allocated to the broker per-partition can be fully utilized without overloading brokers.

TenantPartitionAssignor(ClusterDescriber, String, PartitionPlacementStrategy, boolean) - Constructor for class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor

TenantPartitionAssignor.TopicInfo - Class in io.confluent.kafka.multitenant.assignor

Topic details from new topic or partition create request.

TenantPartitionAssignorBuilder - Class in io.confluent.kafka.multitenant.assignor

TenantPartitionAssignorBuilder() - Constructor for class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder

tenantPartitionMetricTags(String, TopicPartition) - Static method in class io.confluent.kafka.multitenant.metrics.utils.PartitionMetricUtils

Generates the metric tags used to index a metric by tenant and topic partition.

tenantPrefix() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

TenantQuotaCallback - Class in io.confluent.kafka.multitenant.quota

TenantQuotaCallback() - Constructor for class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

TenantSanitizer - Interface in io.confluent.kafka.multitenant.audit

TimeIntervalMetricSampler - Class in io.confluent.kafka.multitenant.metrics.utils

A MetricSampler that samples at most once every intervalNanos.

TimeIntervalMetricSampler(Time, long) - Constructor for class io.confluent.kafka.multitenant.metrics.utils.TimeIntervalMetricSampler

timestamp() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

TokenBearerServerLoginCallbackHandler - Class in io.confluent.kafka.server.plugins.auth.token

An abstract CallbackHandler for the OAuthLoginModule.

TokenBearerServerLoginCallbackHandler() - Constructor for class io.confluent.kafka.server.plugins.auth.token.TokenBearerServerLoginCallbackHandler

TokenBearerValidatorCallbackHandler - Class in io.confluent.kafka.server.plugins.auth.token

A CallbackHandler that recognizes TokenBearerValidatorCallbackHandler for validating a Authentication Tokens issued by Confluent.

TokenBearerValidatorCallbackHandler() - Constructor for class io.confluent.kafka.server.plugins.auth.token.TokenBearerValidatorCallbackHandler

TOPIC_CONFIG_SYNC_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

TOPIC_CONFIG_SYNC_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

TOPIC_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

TopicBasedLoginModule - Class in io.confluent.kafka.server.plugins.auth

TopicBasedLoginModule() - Constructor for class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule

TopicBasedPhysicalClusterMetadata - Class in io.confluent.kafka.multitenant

Responsible for keeping tenant (lkc) metadata in memory, and updating it and related data as needed.

TopicBasedPhysicalClusterMetadata(Metrics) - Constructor for class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

TopicBasedPhysicalClusterMetadata(Metrics, Time) - Constructor for class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata

TopicBasedPlainSaslAuthenticator - Class in io.confluent.kafka.server.plugins.auth

TopicBasedPlainSaslAuthenticator(BaseMultiTenantSaslSecretsStore, String, CCloudTrafficType, List<String>, Collection<String>) - Constructor for class io.confluent.kafka.server.plugins.auth.TopicBasedPlainSaslAuthenticator

TopicBasedPlainSaslAuthenticator(Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.auth.TopicBasedPlainSaslAuthenticator

TopicBasedSaslServerFactory - Class in io.confluent.kafka.server.plugins.auth

TopicBasedSaslServerFactory() - Constructor for class io.confluent.kafka.server.plugins.auth.TopicBasedSaslServerFactory

TopicBasedSaslServerProvider - Class in io.confluent.kafka.server.plugins.auth

TopicBasedTrafficNetworkIdRoutesUpdater - Class in io.confluent.kafka.traffic

TopicBasedTrafficNetworkIdRoutesUpdater(MetadataCache, Map<String, ?>, Metrics) - Constructor for class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater

TopicBasedTrafficNetworkIdRoutesUpdater(MetadataCache, Map<String, ?>, Metrics, Time) - Constructor for class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater

TopicBasedTrafficNetworkIdRoutesUpdater.State - Enum Class in io.confluent.kafka.traffic

TopicInfo(int, short, int) - Constructor for class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo

topicPolicyConfig() - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

TopicPolicyConfig - Class in io.confluent.kafka.server.plugins.policy

TopicPolicyConfig(Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

toSend(RequestHeader, AbstractRequest, long) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor

toString() - Method in record class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiSensorsMetricsRequestContext

Returns a string representation of this record class.

toString() - Method in class io.confluent.kafka.multitenant.serde.EventsMetadataHeader

toString() - Method in class io.confluent.kafka.multitenant.serde.LogicalClusterMetadataRecord

toString() - Method in class io.confluent.kafka.multitenant.SpiffeIdPrincipalExtractor

toString() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

totalPartitions() - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo

TRAFFIC_NETWORK_ID_VALIDATION_MODE_KEY - Static variable in enum class io.confluent.kafka.server.plugins.auth.TrafficNetworkIdValidationMode

trafficAllowed(boolean, Optional<String>, DefaultDataPolicyContext, Collection<String>) - Method in enum class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyValidationMode

Validate if the supplied environmentId and networkType are allowed to talk to this cluster.

trafficAllowed(Optional<String>, TrafficNetworkIdRoutes) - Method in enum class io.confluent.kafka.server.plugins.auth.TrafficNetworkIdValidationMode

Validate if the supplied NetworkId is allowed to talk to this cluster's network.

TrafficNetworkIdAllowedRoutes - Class in io.confluent.kafka.traffic

Pojo representing the JSON value pushed to the CDC topic for the allowed network IDs on this networkId.

TrafficNetworkIdAllowedRoutes(List<String>, List<String>) - Constructor for class io.confluent.kafka.traffic.TrafficNetworkIdAllowedRoutes

TrafficNetworkIdAuthenticator - Class in io.confluent.kafka.server.plugins.auth

This class is used to authenticate networkID authentication logic between various sasl mechanisms.

TrafficNetworkIdAuthenticator(TrafficNetworkIdRoutes, TrafficNetworkIdValidationMode, Consumer<String>) - Constructor for class io.confluent.kafka.server.plugins.auth.TrafficNetworkIdAuthenticator

TrafficNetworkIdValidationMode - Enum Class in io.confluent.kafka.server.plugins.auth

Enum class that represents different modes of NetworkId validation in the authenticator.

transform(AclBindingFilter) - Method in class io.confluent.kafka.link.MultiTenantAclBindingFilterTransformer

transformAclFilter(String, String, AclBindingFilter) - Static method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

transformed() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext

TRUST_PROVIDER_CONFIG - Static variable in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustProvider

trustCache() - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

type() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

U

unwrap(byte[], int, int) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

UPDATABLE_BROKER_CONFIGS - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

UPDATABLE_CLUSTER_LINK_CONFIGS - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

UPDATABLE_CLUSTER_LINK_INTERNAL_CONFIGS - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

UPDATABLE_GROUP_CONFIGS - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

updatableFreightTopicConfig(String) - Static method in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

updatableTopicConfig(String, boolean) - Static method in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

updateClusterDescriber(ClusterDescriber) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder

updateClusterMetadata(ClientQuotaClusterDescriber) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

Handle metadata update.

updateDynamicQuotas(Map<Map<String, String>, Map<String, Long>>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

updateQuota(ClientQuotaType, ClientQuotaEntity, double) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

updateQuotas(Map<String, MultiTenantQuotaConfig>, MultiTenantQuotaConfig) - Static method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

Update provisioned tenant quota configuration and/or default tenant quota.

updateTenantFlexFanoutEnabled(String, Boolean) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

updateTenantState(KafkaLogicalClusterMetadata) - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager

updateTopicPartitionsOnCompactConfigChange(String, String, String, int) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

This file keeps track of a few tenant level andtopic level counters.

updateUserQuotas(String, Map<String, MultiTenantQuotaConfig>, MultiTenantQuotaConfig) - Static method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

USER_ACCOUNT_REQUEST_DENIED_RATE_PER_MINUTE - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer.TenantAuthorizerMetrics

USER_DELETION_HANDLER_EVENT_COUNT - Static variable in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

USER_DELETION_HANDLER_EVENT_FAILURE_RATE - Static variable in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

USER_ID_TO_RESOURCE_ID_MAPPING_MISSING_RATE_PER_MINUTE - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer.TenantAuthorizerMetrics

USER_METADATA_COUNT - Static variable in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

USER_METADATA_EVENT_FAILURE_RATE - Static variable in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

USER_METADATA_EVENT_RATE - Static variable in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

USER_METADATA_TOPIC_LOAD_TIME - Static variable in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

USER_RESOURCE_ID - Static variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator

UserDeletionEventHandler - Class in io.confluent.kafka.server.plugins.auth

This class is responsible for processing user deletion events and performing soft deletion of ACLs associated with the deleted user.

UserDeletionEventHandler(Map<String, ?>, Optional<Plugin<Authorizer>>, Metrics, int) - Constructor for class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

UserDeletionEventHandler(Map<String, ?>, Optional<Plugin<Authorizer>>, Metrics, int, Time) - Constructor for class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

UserDeletionEventHandler.State - Enum Class in io.confluent.kafka.server.plugins.auth

userIdentifier() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer

userIdentifier() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

userIdToUserResourceId(String) - Method in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

UserMetaDataKey - Class in io.confluent.kafka.server.plugins.auth

userMetaDataKeyUserMetaDataValueMap - Variable in class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler

UserMetaDataValue - Class in io.confluent.kafka.server.plugins.auth

username - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslCredentials

userResourceId() - Method in class io.confluent.kafka.server.plugins.auth.UserMetaDataKey

userResourceId(OAuthBearerJwsToken) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder

userResourceIdToUserId(String) - Method in class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

usesMetadataFromThisKafkaCluster() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

usesMetadataFromThisKafkaCluster() - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider

Utils - Class in io.confluent.kafka.multitenant.utils

Utils() - Constructor for class io.confluent.kafka.multitenant.utils.Utils

uuid() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent

V

validate(Optional<String>, String, Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy

validate(AlterConfigPolicy.RequestMetadata) - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy

We don't allow any config updates using the external listener where all principals are MultiTenantPrincipals.

validate(CreateTopicPolicy.RequestMetadata) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

validateBrokerConfigs(AlterConfigPolicy.RequestMetadata) - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig

validateClusterLinkConfigs(Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

validateGroupConfigs(AlterConfigPolicy.RequestMetadata) - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.GroupPolicyConfig

validatePublicKey(String) - Static method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerServerLoginCallbackHandler

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy

validateTlsResult(Logger, NetworkContext) - Static method in class io.confluent.kafka.multitenant.utils.MultiTenantPrincipalBuilderUtils

Validate mTLS client validation metadata in PROXY protocol headers if the client cert was validated by envoy.

validateTopicConfigs(Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

validateTopicConfigs(Map<String, String>, TopicType) - Method in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

validBrokerRackSet() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

valueOf(String) - Static method in enum class io.confluent.kafka.multitenant.PhysicalClusterMetadata.State

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer.State

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyValidationMode

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore.State

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.server.plugins.auth.SniValidationMode

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.server.plugins.auth.TrafficNetworkIdValidationMode

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler.State

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater.State

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.confluent.kafka.multitenant.PhysicalClusterMetadata.State

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer.State

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.server.plugins.auth.DefaultDataPolicyValidationMode

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore.State

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.server.plugins.auth.SniValidationMode

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.server.plugins.auth.TrafficNetworkIdValidationMode

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.server.plugins.auth.UserDeletionEventHandler.State

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.traffic.TopicBasedTrafficNetworkIdRoutesUpdater.State

Returns an array containing the constants of this enum class, in the order they are declared.

verifyClientCerts(X509Certificate[]) - Method in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

verifyServerCerts(X509Certificate[]) - Method in class io.confluent.kafka.server.plugins.ssl.ConfluentTrustManager

VISIBLE_BROKER_CONFIGS - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

VISIBLE_CLUSTER_LINK_CONFIGS - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

visibleTopicConfig(String, boolean) - Static method in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

W

wrap(byte[], int, int) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer

write(EntityType, String) - Method in class io.confluent.kafka.link.LinkContext

write(EntityType, String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext

write(EntityType, Message) - Method in class io.confluent.kafka.link.LinkContext

write(EntityType, Message) - Method in class io.confluent.kafka.multitenant.schema.TenantContext

writeKeyPair(OutputStream, KeyPair) - Static method in class io.confluent.common.security.utils.PemUtils

writePublicKey(OutputStream, PublicKey) - Static method in class io.confluent.common.security.utils.PemUtils

writer() - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

writeTo(ConsumerRecord<byte[], byte[]>, PrintStream) - Method in class io.confluent.kafka.multitenant.quota.TenantClientQuotaFormatter

writeTo(ConsumerRecord<byte[], byte[]>, PrintStream) - Method in class io.confluent.kafka.multitenant.serde.RoleBindingMetadataFormatter

Z

ZoneDataMetricsRequestContext(MultiTenantPrincipal, String, ApiKeys, short, boolean, Optional<String>, Optional<String>, Optional<String>, String) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.ZoneDataMetricsRequestContext

zoneTaggedRequestMetricsEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

A B C D E F G H I J K L M N O P Q R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form