Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W 

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
 
AbstractConnectionSensorBuilder.ConnectionCountSensorCreator - Class in io.confluent.kafka.multitenant.metrics
 
AbstractConnectionSensorBuilder.ConnectionMeterSensorCreator - Class in io.confluent.kafka.multitenant.metrics
 
AbstractPolicyConfig - Class in io.confluent.kafka.server.plugins.policy
 
AbstractPolicyConfig(ConfigDef, Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
 
accessRule(StandardAcl) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
accessRule(AclEntry) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
accountId() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
ACL_SYNC_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
ACL_SYNC_MS_MAX_CONFIG_DOC - 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
 
ACL_SYNC_MS_MIN_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
AclAuthorizers() - Constructor for class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer.AclAuthorizers
 
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
 
AclProvider - Class in io.confluent.kafka.security.authorizer.acl
AclProvider implementation for ACLs stored in Zookeeper.
AclProvider() - Constructor for class io.confluent.kafka.security.authorizer.acl.AclProvider
 
acls(AclBindingFilter) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
acls(AclBindingFilter) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
actionForAuthorizeByResourceType(RequestContext, Operation, ResourceType) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
activeAuthenticatedConnectionsCount - Variable in class io.confluent.kafka.multitenant.metrics.ConnectionSensors
 
activeNodeUrls(String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore
 
addAcl(Uuid, ConfluentStandardAcl) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
addMatchingRules(ResourceAuthorizeRules, KafkaPrincipal, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
addMatchingRules(ResourceAuthorizeRules, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
addMatchingRules(ResourceAuthorizeRules, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in interface io.confluent.kafka.security.authorizer.acl.ExtendedAccessRuleProvider
 
addMatchingRules(ResourceAuthorizeRules, KafkaPrincipal, 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
 
address() - Method in class io.confluent.common.EndPoint
 
addTenantPrefix(String, String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 
addTenantPrefix(String) - 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
 
AggregateTenantMetricsContext(ApiKeys) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.AggregateTenantMetricsContext
 
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
 
apiKey() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.AggregateTenantMetricsContext
 
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
 
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.AclProvider
 
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) - Constructor for class io.confluent.kafka.server.plugins.auth.AuthAttemptCache
Create an AuthAttemptCache.
AuthAttemptCache() - 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(String, String, Optional<PathAwareSniHostName>, Optional<String>) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
Authenticate user by checking username, password, cluster id and network region id.
AUTHENTICATION_FAILED_MSG - Static variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
Visible for testing
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.acl.AclProvider
 
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
 
authRate - Variable in class io.confluent.kafka.multitenant.metrics.ConnectionSensors
 
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
 
brokerRequestPercentage() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
build() - Method in class io.confluent.kafka.multitenant.metrics.ApiKeyConnectionSensorBuilder
 
build() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensorBuilder
 
build() - Method in class io.confluent.kafka.multitenant.metrics.IpConnectionSensorBuilder
 
build() - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
build(AuthenticationContext) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
build(AuthenticationContext) - Method in class io.confluent.kafka.multitenant.UserTenantPrincipalBuilder
 
build() - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder
Construct new JwtIssuerAuthCache instance.
builder() - Static method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache
 
buildResponseSend(AbstractResponse) - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 

C

CCLOUD_INTERNAL_USER - Static variable in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
checkPolicyMax(Map<String, String>, String, String) - Method in class io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
 
checkPolicyMin(Map<String, String>, String, String) - Method in class io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
 
checkSniHostNameMatched(OAuthBearerExtensionsValidatorCallback, String, String, SniValidationMode) - Method in class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler
 
clientId() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext
 
close() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
close(String) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
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.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.TokenBearerServerLoginCallbackHandler
 
close() - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerValidatorCallbackHandler
 
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.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler
 
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
 
collectAuthorizers() - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
combineAclDeleteResults(List<AclBindingFilter>, List<? extends CompletionStage<AclDeleteResult>>, List<? extends CompletionStage<AclDeleteResult>>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
Combine AclDeleteResults present in both list and convert final Acls based on aclBindingFilters, for each index.
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
 
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_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
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor
 
configure(Map<String, String>) - Method in class io.confluent.kafka.link.MultiTenantAclBindingFilterTransformer
 
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.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(KafkaBasedLog<byte[], byte[]>, String) - Method in class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer
 
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.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.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.oauth.MockBasicAuthStore
 
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.TokenBearerServerLoginCallbackHandler
 
configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerValidatorCallbackHandler
 
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.security.auth.dataplane.JwtIssuerAuthCache
 
configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler
 
configureAccessRuleProviders(Map<String, Object>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
configureMetrics(Metrics) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor
 
configureProviders(List<AccessRuleProvider>, GroupProvider, MetadataProvider, AuditLogProvider) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
configureServerInfo(ConfluentAuthorizerServerInfo) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
configureServerInfo(ConfluentAuthorizerServerInfo) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
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
 
ConfluentServerAuthorizer.AclAuthorizers - Class in io.confluent.kafka.security.authorizer
 
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
 
connectionString() - Method in class io.confluent.common.EndPoint
 
CONSUMER_OFFSET_SYNC_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
CONSUMER_OFFSET_SYNC_MS_MAX_CONFIG_DOC - 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
 
CONSUMER_OFFSET_SYNC_MS_MIN_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
consumerByteRate() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
create() - Static method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore
 
createAcls(AuthorizableRequestContext, List<AclBinding>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
createAcls(AuthorizableRequestContext, List<AclBinding>, Optional<String>) - 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.security.authorizer.ConfluentServerAuthorizer
 
createAdminClient(String) - Method in class io.confluent.kafka.multitenant.SslCertificateManager
 
createAdminClient(String) - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
 
createAdminClient(String) - Static method in class io.confluent.kafka.multitenant.utils.Utils
 
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
 
createConfluentAdmin(String) - Static method in class io.confluent.kafka.multitenant.utils.Utils
 
createSaslServer(String, String, String, Map<String, ?>, CallbackHandler) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer.PlainSaslServerFactory
 
createSensor(Map<T, ? extends AbstractSensorCreator>, T, String) - Method in class io.confluent.kafka.multitenant.metrics.AbstractConnectionSensorBuilder
 
createSensor(Map<T, ? extends AbstractSensorCreator>, T, String) - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
createSensors(Map<String, MultiTenantSaslConfigEntry>) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
 
CreateTopicPolicy - Class in io.confluent.kafka.server.plugins.policy
 
CreateTopicPolicy() - Constructor for class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
creationDate() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
creationDate() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata.LifecycleMetadata
 

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_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_DELETE_RETENTION_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_HEALTHCHECK_MAX_CONSUMER_RATE - Static variable in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
DEFAULT_HEALTHCHECK_MAX_PRODUCER_RATE - Static variable in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
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_TOPICS_PER_CLUSTER - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_MIN_NETWORK_BYTE_RATE - Static variable in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
DEFAULT_MULTI_TENANT_AUDIT_LOGGER_ENABLE_CONFIG - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig
 
DEFAULT_NETWORK_QUOTA_OVERHEAD_PERCENTAGE - Static variable in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
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_REQUEST_PERCENTAGE_PER_BROKER - Static variable in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
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_MECHANISMS_ALLOWED - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DEFAULT_SECURITY_PROTOCOL_MAP - Static variable in class io.confluent.common.EndPoint
 
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_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
 
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 in io.confluent.kafka.multitenant.audit
 
DELETE_RETENTION_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DELETE_RETENTION_MS_MAX_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>, Optional<String>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
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>) - 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
 
deleteCredential(String) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
 
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
 
deletionDate() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata.LifecycleMetadata
 
DELIMITER - Static variable in class io.confluent.kafka.multitenant.schema.TenantContext
 
deserialize(byte[]) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
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
 
deserialize(byte[]) - Method in class io.confluent.kafka.multitenant.UserTenantPrincipalBuilder
 
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

enableDynamicQuota(boolean) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
EndPoint - Class in io.confluent.common
Represents a network endpoint.
EndPoint(String, int, SecurityProtocol) - Constructor for class io.confluent.common.EndPoint
 
EndPoint(String, int, ListenerName, SecurityProtocol) - Constructor for class io.confluent.common.EndPoint
 
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
 
ensureOpen() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
environmentId() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
equalQuotaPerBrokerOrUnlimited(ClientQuotaType, int, Long) - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
equals(Object) - Method in class io.confluent.common.EndPoint
 
equals(Object) - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
equals(Object) - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata.LifecycleMetadata
 
equals(Object) - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
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
 
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
 
extractTenant(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 
extractTenantPrefix(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 

F

fail(int, String) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache
 
FAILED_AUTH_CACHE - Static variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 
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
 
FileBasedSaslServerProvider() - Constructor for class io.confluent.kafka.server.plugins.auth.FileBasedSaslServerProvider
 
filter(String, String) - Static method in class io.confluent.kafka.multitenant.tools.DeleteAclsForMultiTenantPrincipal
 
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
findRule(Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
findRule(Set<KafkaPrincipal>, String, Action) - Method in interface io.confluent.kafka.security.authorizer.acl.ExtendedAccessRuleProvider
 
findRule(KafkaPrincipal, 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
 
fromProtobuf(LogicalCluster) - Static method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
fromProtobuf(EventsMetadata) - Static method in class io.confluent.kafka.multitenant.serde.EventsMetadataHeader
 
fromString(String) - Static method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
 
fullUpdate(Iterator<Map.Entry<String, Integer>>) - 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(String, String) - Method in class io.confluent.kafka.server.plugins.auth.AuthAttemptCache
Return the hash for the [username, password] if any
get(AuthKey) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache
 
get(List<AppConfigurationEntry>, Map<String, ?>) - Method in interface io.confluent.kafka.server.plugins.auth.SaslServerSupplier
 
getAction(Action, ResourcePattern, KafkaPrincipal) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
getAction(Action, ResourcePattern, KafkaPrincipal) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
getAuthorizationID() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
getBootstrapBrokerForListener(String, Map<String, ?>) - Static method in class io.confluent.common.InterClusterConnection
 
getConsumerConfig(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
 
getEndToEndSensor() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
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
 
getScope() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
getSessionUuid(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
getSessionUuid(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
 
getStartSensor() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
getText() - Method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
 
getTopicClientId(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
getTopicConfig() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 

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.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
 
handleSocketServerInitialized(String) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
handleSocketServerInitialized(String) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
hashCode() - Method in class io.confluent.common.EndPoint
 
hashCode() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
hashCode() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata.LifecycleMetadata
 
hashCode() - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
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
 
hasQuotaLimit(ClientQuotaType) - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
hasTenantPrefix(String, String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 
hasTenantPrefix(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
HEALTHCHECK_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
host() - Method in class io.confluent.common.EndPoint
 

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
 
inactiveClusters() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
Return all logical clusters that are deactivated
initialize(Subject, CallbackHandler, Map<String, ?>, Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule
 
initialize(List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator
 
initialize() - Static method in class io.confluent.kafka.server.plugins.auth.FileBasedSaslServerProvider
 
initialize(Subject, CallbackHandler, Map<String, ?>, Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule
 
initialize(List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedPlainSaslAuthenticator
 
initialize() - Static method in class io.confluent.kafka.server.plugins.auth.TopicBasedSaslServerProvider
 
intConfig(Map<String, ?>, String) - Static method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
 
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
 
INTERNAL_LISTENER_CONFIG_DOC - 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
 
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.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.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.security.auth.dataplane - package io.confluent.security.auth.dataplane
 
io.confluent.security.auth.provider.oauth - package io.confluent.security.auth.provider.oauth
 
IpConnectionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics
 
IpConnectionSensorBuilder(Metrics, MultiTenantPrincipal, InetAddress) - Constructor for class io.confluent.kafka.multitenant.metrics.IpConnectionSensorBuilder
 
isActive() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
isApiAllowed(ApiKeys) - Static method in class io.confluent.kafka.link.ClusterLinkApis
 
isApiAllowed(ApiKeys) - 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
 
isHealthcheckLogicalCluster() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
Returns true if this is a healthcheck logical cluster.
isMasterWriter() - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore
 
isNewTopic() - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo
 
isSchemaValidationEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
 
isSniHostNameMatched(OAuthBearerExtensionsValidatorCallback, String, String, SniValidationMode) - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler
 
isSuperUser(KafkaPrincipal, KafkaPrincipal, Action) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
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.AclProvider
 
isSuperUser(KafkaPrincipal, Scope) - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider
 
isTenantPrefixed(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 
isTransformRequired(ResourceType) - Method in class io.confluent.kafka.link.LinkContext
 
isTransformRequired(ResourceType) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 
isTransformRequired(ConfigResource.Type) - 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.
isValid() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
Returns true if metadata values are valid

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

k8sClusterId() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
KAFKA_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
kafkaLogicalClusterIds() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
kafkaLogicalClusterIds() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
KafkaLogicalClusterMetadata - Class in io.confluent.kafka.multitenant
Represents logical cluster metadata
KafkaLogicalClusterMetadata(String, String, String, String, String, String, Long, Long, Long, Long, Long, Long, Integer, KafkaLogicalClusterMetadata.LifecycleMetadata, Integer, String, String) - Constructor for class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
KafkaLogicalClusterMetadata.LifecycleMetadata - Class in io.confluent.kafka.multitenant
 
KafkaVerificationKeyResolver - Class in io.confluent.kafka.server.plugins.auth.oauth
 
KafkaVerificationKeyResolver(String, String) - Constructor for class io.confluent.kafka.server.plugins.auth.oauth.KafkaVerificationKeyResolver
 
keyResolver(Collection<Constraint>) - 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
 
lifecycleMetadata() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
LifecycleMetadata(String, String, Date, Date) - Constructor for class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata.LifecycleMetadata
 
LINK_HEALTHCHECK_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
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
 
listenerName() - Method in class io.confluent.common.EndPoint
 
load(String, long, long) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsLoader
 
loadKeyPair(InputStream) - Static method in class io.confluent.common.security.utils.PemUtils
 
loadPublicKey(InputStream) - Static method in class io.confluent.common.security.utils.PemUtils
 
loadSecrets() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator
 
loadSecrets() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 
loadSecrets() - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedPlainSaslAuthenticator
 
loadSnapshot(Map<Uuid, ConfluentStandardAcl>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
log - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 
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() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
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
 
logicalClusterName() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata.LifecycleMetadata
 
logicalClusterName() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
logicalClusterType() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
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_MESSAGE_BYTES_MAX_CONFIG_DOC - 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_CLUSTER_CONFIG_DOC - 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_PARTITIONS_PER_TENANT_CONFIG_DOC - 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
 
MAX_TOPICS_PER_CLUSTER_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
maxPartitions() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
maybeBuildAssignor(Optional<KafkaPrincipal>) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder
Builds a #TopicReplicaAssignor to be used for replica assignment.
mayDeny() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
mayDeny() - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
mayDeny() - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider
 
metadata(String) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
metrics() - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
metricsGroup() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.AggregateTenantMetricsContext
 
metricsGroup() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext
 
MetricsRequestContext(MultiTenantPrincipal, String, ApiKeys) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext
 
metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.AggregateTenantMetricsContext
 
metricTags(String, String) - Static method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeyMetricsContext
 
metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeyMetricsContext
 
metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantIpMetricsContext
 
metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext
 
MIN_ISR - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
MockBasicAuthStore - Class in io.confluent.kafka.server.plugins.auth.oauth
 
MockBasicAuthStore() - 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
 
mode - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 
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(Map<String, ?>) - Constructor for class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
 
MultiTenantInterceptorConfig(boolean, boolean, 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
 
MultiTenantRequestContext - Class in io.confluent.kafka.multitenant
 
MultiTenantRequestContext(RequestHeader, String, InetAddress, MultiTenantPrincipal, ListenerName, SecurityProtocol, ClientInformation, PathAwareSniHostName, Time, Metrics, TenantMetrics, MultiTenantInterceptorConfig, Optional<ClusterLinkSourceMetrics>, boolean, Optional<KafkaPrincipalSerde>, AuthenticationContext) - 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(String) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder
 
name() - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache
networkQuotaOverhead() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
newContext(RequestHeader, String, InetAddress, KafkaPrincipal, ListenerName, SecurityProtocol, ClientInformation, Metrics, PathAwareSniHostName, boolean, Optional<KafkaPrincipalSerde>, AuthenticationContext) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor
 
newInstance(Map<String, ?>) - Static method in class io.confluent.kafka.server.plugins.auth.oauth.JwtAuthenticatorConfig
 
NotTenantPrefixedException(String) - Constructor for exception 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
 

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
 
onAuthenticatedConnection(String, InetAddress, KafkaPrincipal, Metrics) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor
 
onAuthenticatedDisconnection(String, InetAddress, KafkaPrincipal, Metrics) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor
 
operation(AclOperation) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
organizationId() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 

P

parentQuotaMetricTags(ClientQuotaType, Map<String, String>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
parse(String) - Static method in class io.confluent.common.EndPoint
 
parse(String, Map<ListenerName, SecurityProtocol>) - Static method in class io.confluent.common.EndPoint
 
parsedResponse(AbstractResponse, short) - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
parseLCM(ConsumerRecord<String, byte[]>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
parseList(Map<String, String>, String) - Method in class io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
 
parseLong(String) - Method in class io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
 
parseRequest(ByteBuffer) - 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) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
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
 
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
 
physicalClusterId() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
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 in io.confluent.kafka.multitenant
 
physicalK8sNamespace() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata.LifecycleMetadata
 
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
 
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) - Constructor for class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
PlainSaslServer(List<AppConfigurationEntry>, SaslAuthenticator, PathAwareSniHostName, 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
 
port() - Method in class io.confluent.common.EndPoint
 
postUpdateBookkeeping() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
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 - Variable 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() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext
 
principal - Variable in class io.confluent.kafka.multitenant.schema.TenantContext
 
principal() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
PRINCIPAL_RESOURCE_ID - Static variable in class io.confluent.kafka.multitenant.audit.DefaultTenantSanitizer
 
producerByteRate() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
providerName() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
providerName() - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
providerName() - Method in class io.confluent.kafka.security.authorizer.acl.StandardAclProvider
 
put(String, String, String) - Method in class io.confluent.kafka.server.plugins.auth.AuthAttemptCache
Cache an authorisation.
put(AuthKey, AuthValue) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache
 

Q

quota(ClientQuotaType) - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
quotaConfig() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
QuotaConfig - Class in io.confluent.kafka.multitenant.quota
 
QuotaConfig(Long, Long, Double, Double, QuotaConfig) - Constructor for class io.confluent.kafka.multitenant.quota.QuotaConfig
 
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
 
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, Message) - 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.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
 
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.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
 
recordEndToEndSensor(KafkaLogicalClusterMetadata) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
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
 
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
 
registerMetrics(Metrics) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
remove(AuthKey) - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache
 
removeAcl(Uuid) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
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(TopicPartition) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
removeTenantPrefix(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX_DOC - 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
 
REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN_DOC - 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
 
REPLICATION_FACTOR_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
replicationFactor() - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo
 
resolvedAddress() - Method in class io.confluent.common.EndPoint
 
resolveKey(JsonWebSignature, List<JsonWebStructure>) - Method in class io.confluent.kafka.server.plugins.auth.oauth.KafkaVerificationKeyResolver
 
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_MAX_CONFIG_DOC - 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
 

S

SASL_MECHANISMS_ALLOWED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
SASL_MECHANISMS_ALLOWED_CONFIG_DOC - 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
securityProtocol() - Method in class io.confluent.common.EndPoint
 
SEGMENT_BYTES_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
SEGMENT_BYTES_MAX_CONFIG_DOC - 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_BYTES_MIN_CONFIG_DOC - 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
 
SEGMENT_MS_MIN_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
sensorCreators() - Method in class io.confluent.kafka.multitenant.metrics.ApiKeyConnectionSensorBuilder
 
sensorCreators() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensorBuilder
 
sensorCreators() - Method in class io.confluent.kafka.multitenant.metrics.IpConnectionSensorBuilder
 
sensorCreators() - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
sensorSuffix(String, TenantMetrics.TenantMetricsContext) - Method in class io.confluent.kafka.multitenant.metrics.AbstractConnectionSensorBuilder
 
sensorSuffix(String, TenantMetrics.MetricsRequestContext) - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.AggregateTenantMetricsContext
 
sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.ApiKeyMetricsContext
 
sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantIpMetricsContext
 
sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext
 
SEQUENCE_ID_STRING_HEADER_KEY - Static variable in class io.confluent.kafka.multitenant.utils.Utils
 
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.multitenant.UserTenantPrincipalBuilder
 
sessionUuid(String) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder
 
sessionUuid() - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache
 
setAclMutator(AclMutator) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
setData(Map<String, Object>) - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
shouldIntercept() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
shutdown() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
After this method is called, querying the cache will throw IllegalStateException
sizeOfRemovedPrefixes(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
SNI_HOST_NAME_VALIDATION_MODE_KEY - Static variable in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
 
sniHostNameMatches(String, Optional<String>, Optional<PathAwareSniHostName>) - Method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
Validate if the supplied cluster Id matches with the ground truth.
SniValidationMode - Enum 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
 
SSL_CIPHER_SUITES_ALLOWED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
sslCertificateManager - Variable in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
SslCertificateManager - Class in io.confluent.kafka.multitenant
 
sslCertificateManager - Variable in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
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(ConfluentAuthorizerServerInfo, Map<String, ?>) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
start(Map<String, Object>, Collection<Endpoint>) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
start() - Method in class io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer
 
start(Map<String, Object>, Collection<Endpoint>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
start(ConfluentAuthorizerServerInfo, Map<String, ?>) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
start(AuthorizerServerInfo) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
start(AuthorizerServerInfo) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
startLog() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
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
 
storageBytes() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
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.
SUCCESSFUL_AUTH_CACHE - Static variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 

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, String) - Method in class io.confluent.kafka.multitenant.audit.DefaultTenantSanitizer
 
tenantAuditEvent(AuditEvent) - Method in class io.confluent.kafka.multitenant.audit.DefaultTenantSanitizer
 
tenantAuditEvent(AuditEvent, String) - Method in interface io.confluent.kafka.multitenant.audit.TenantSanitizer
 
tenantAuditEvent(AuditEvent) - Method in interface io.confluent.kafka.multitenant.audit.TenantSanitizer
 
tenantAuthorizerMetrics() - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
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 in io.confluent.kafka.multitenant.quota
 
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
 
tenantLifecycleManager - Variable in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
TenantLifecycleManager - Class in io.confluent.kafka.multitenant
 
TenantLifecycleManager(Map<String, ?>, Time) - Constructor for class io.confluent.kafka.multitenant.TenantLifecycleManager
 
tenantLifecycleManager - Variable in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
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.AggregateTenantMetricsContext - Class in io.confluent.kafka.multitenant.metrics
See: CNK-1347 Currently, the request metrics tracked by the metrics API (Telemetry reporter) and what DataDog charts track internally are not equivalent.
TenantMetrics.ApiKeyMetricsContext - Class in io.confluent.kafka.multitenant.metrics
 
TenantMetrics.MetricsRequestContext - Class in io.confluent.kafka.multitenant.metrics
 
TenantMetrics.TenantIpMetricsContext - Class in io.confluent.kafka.multitenant.metrics
 
TenantMetrics.TenantMetricsContext - Class in io.confluent.kafka.multitenant.metrics
 
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) - 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
 
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
 
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_MAX_CONFIG_DOC - 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_CONFIG_SYNC_MS_MIN_CONFIG_DOC - 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
This holds metadata passed from CCloud related to this physical cluster
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(Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.auth.TopicBasedPlainSaslAuthenticator
 
TopicBasedPlainSaslAuthenticator(BaseMultiTenantSaslSecretsStore) - 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
 
TopicBasedSaslServerProvider() - Constructor for class io.confluent.kafka.server.plugins.auth.TopicBasedSaslServerProvider
 
TopicInfo(int, short, int) - Constructor for class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo
 
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 class io.confluent.common.EndPoint
 
toString() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata.LifecycleMetadata
 
toString() - Method in class io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata
 
toString() - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
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.security.audit.event.ConfluentAuthenticationEvent
 
totalPartitions() - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo
 
transform(AclBindingFilter) - Method in class io.confluent.kafka.link.MultiTenantAclBindingFilterTransformer
 
transformAclFilter(String, String, AclBindingFilter) - Static method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
transformDestToSource(DescribeConfigsRequestData.DescribeConfigsResource) - Method in class io.confluent.kafka.link.LinkContext
 
transformed() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
transformSourceToDest(DescribeConfigsResponseData.DescribeConfigsResult) - Method in class io.confluent.kafka.link.LinkContext
 
trustCache() - Method in class io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore
 
type() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 

U

UNLIMITED_QUOTA - Static variable in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
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
 
updatableTopicConfig(String, boolean) - Static method in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 
updateCache(ResourcePattern, AclAuthorizer.VersionedAcls) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
updateClusterDescriber(ClusterDescriber) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder
 
updateClusterMetadata(Cluster) - 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
 
updateLogicalCluster(String, Long, KafkaLogicalClusterMetadata) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
updateMaxPartitionsIfNecessary(KafkaLogicalClusterMetadata, KafkaLogicalClusterMetadata) - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
 
updateQuota(ClientQuotaType, ClientQuotaEntity, double) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
updateQuotas(Map<String, QuotaConfig>, QuotaConfig) - Static method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
Update provisioned tenant quota configuration and/or default tenant quota.
updateSecretsLoader(BaseMultiTenantSaslSecretsStore) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
updateTenantState(KafkaLogicalClusterMetadata) - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
 
updateUserQuotas(String, Map<String, QuotaConfig>, QuotaConfig) - 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_ID_TO_RESOURCE_ID_MAPPING_MISSING_RATE_PER_MINUTE - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer.TenantAuthorizerMetrics
 
USER_RESOURCE_ID - Static variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 
userIdentifier() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer
 
userIdentifier() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
userResourceId(OAuthBearerJwsToken) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
UserTenantPrincipalBuilder - Class in io.confluent.kafka.multitenant
Each user has its own tenant id and namespace.
UserTenantPrincipalBuilder() - Constructor for class io.confluent.kafka.multitenant.UserTenantPrincipalBuilder
 
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
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(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(Optional<String>, String, Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy
 
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
 
validateConfigsAreUpdatable(Map<String, String>, Predicate<String>) - Static method in class io.confluent.kafka.server.plugins.policy.PolicyUtils
 
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
 
validateTopicConfigs(Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
valueOf(String) - Static method in enum io.confluent.kafka.multitenant.PhysicalClusterMetadata.State
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer.State
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.confluent.kafka.multitenant.PhysicalClusterMetadata.State
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer.State
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
Returns an array containing the constants of this enum type, in the order they are declared.
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

withQuota(ClientQuotaType, double) - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
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, Message) - 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.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.serde.RoleBindingMetadataFormatter
 
A B C D E F G H I J K L M N O P Q R S T U V W 
Skip navigation links