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

A

abort() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule
 
AbstractPolicyConfig - Class in io.confluent.kafka.server.plugins.policy
 
AbstractPolicyConfig(ConfigDef, Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
 
AbstractTransformableType<T extends TransformContext> - Class in io.confluent.kafka.multitenant.schema
 
AbstractTransformableType(Type) - Constructor for class io.confluent.kafka.multitenant.schema.AbstractTransformableType
 
accessRule(AclEntry) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
accountId() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
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
 
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
 
aclOperation(Operation) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
AclProvider - Class in io.confluent.kafka.security.authorizer.acl
 
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
 
activeAuthenticatedConnectionsCount - Variable in class io.confluent.kafka.multitenant.metrics.ConnectionSensors
 
address() - Method in class io.confluent.common.EndPoint
 
addTenantPrefix(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
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.MetricsRequestContext
 
assignPartitionsForExistingTopics(String, Map<String, Integer>) - Method in class io.confluent.kafka.multitenant.quota.TenantPartitionAssignor
Assign partitions for a CreatePartitions request.
assignPartitionsForNewTopics(String, Map<String, TenantPartitionAssignor.TopicInfo>) - Method in class io.confluent.kafka.multitenant.quota.TenantPartitionAssignor
Assign partitions for a CreateTopics request.
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
authenticate(String, String, Optional<SNIHostName>) - Method in class io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator
Authenticate user by checking username, password and cluster id.
AUTHENTICATION_FAILED_MSG - Static variable in class io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator
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
 
AuthenticationStats - Class in io.confluent.kafka.server.plugins.auth.stats
 
AuthenticationStatsMBean - Interface in io.confluent.kafka.server.plugins.auth.stats
 
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
 
authRate - Variable in class io.confluent.kafka.multitenant.metrics.ConnectionSensors
 
AuthUtils - Class in io.confluent.kafka.server.plugins.auth
 

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.LogicalClusterMetadata
 
build() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensorBuilder
 
build() - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
build(AuthenticationContext) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
build() - Method in class io.confluent.kafka.multitenant.TenantMetadata.Builder
 
build(AuthenticationContext) - Method in class io.confluent.kafka.multitenant.UserTenantPrincipalBuilder
 
Builder(String) - Constructor for class io.confluent.kafka.multitenant.TenantMetadata.Builder
 
buildResponse(AbstractResponse) - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 

C

centralizedAclProvider() - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
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
 
clientId() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext
 
close(String) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
close() - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
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.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
 
CloudUtils - Class in io.confluent.common.security.utils
 
CloudUtils() - Constructor for class io.confluent.common.security.utils.CloudUtils
 
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 - Variable in class io.confluent.kafka.multitenant.TenantMetadata.Builder
 
clusterId - Variable in class io.confluent.kafka.multitenant.TenantMetadata
 
clusterId(String) - Method in class io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator
 
ClusterLinkApis - Class in io.confluent.kafka.link
A cache of TransformableSchema for Cluster Link requests to the source cluster which apply multi-tenant transformations and in future may also be used to support topic renaming.
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
 
commit() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule
 
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, ?>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
Loads the cache and starts listening for directory events in directory specified in ConfluentConfigs.MULTITENANT_METADATA_DIR_CONFIG config.
configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.security.ldap.authorizer.LdapAuthorizer
 
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.CreateTopicPolicy
 
configureAccessRuleProviders(Map<String, Object>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
configureMetrics(Metrics, Time) - 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.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
 
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.LogicalClusterMetadata
 
createAcls(AuthorizableRequestContext, List<AclBinding>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
createAcls(AuthorizableRequestContext, List<AclBinding>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
createAcls(AuthorizableRequestContext, List<AclBinding>, Optional<String>) - Method in class io.confluent.kafka.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
 
createJwtConsumer(PublicKey) - Static method in class io.confluent.common.security.utils.CloudUtils
returns a common JwtConsumer for building/validating JWS tokens for OAuth 2 authentication across CCloud The JWS token must have: - an issuer `iss` claim representing the principal that issued the token - a subject `sub` claim representing the principal who will use the token - a JWT ID `jti` claim which serves as a unique identifier of the token - a issued at `iat` claim which is the time the token was created - an expiration time `exp` claim showing the time after which this token should be considered expired
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.ConnectionSensorBuilder
 
createSensor(Map<T, ? extends AbstractSensorCreator>, T, String) - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
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.LogicalClusterMetadata.LifecycleMetadata
 

D

data() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
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_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.LogicalClusterMetadata
 
DEFAULT_HEALTHCHECK_MAX_PRODUCER_RATE - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
DEFAULT_INTERNAL_LISTENER - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
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_TENANT - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_MIN_NETWORK_BYTE_RATE - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
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.LogicalClusterMetadata
 
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.LogicalClusterMetadata
 
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
 
defaultNumPartitions() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
 
defaultReplicationFactor() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
 
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>) - 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
 
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.LogicalClusterMetadata.LifecycleMetadata
 
DELIMITER - Static variable in class io.confluent.kafka.multitenant.MultiTenantPrincipal
 
DELIMITER - Static variable in class io.confluent.kafka.multitenant.schema.TenantContext
 
DEST_METRICS_GROUP - Static variable in class io.confluent.kafka.link.ClusterLinkInterceptor
 
destPrefix() - Method in class io.confluent.kafka.link.LinkContext
 
destToSource(String) - Method in class io.confluent.kafka.link.LinkContext
 
destToSourceDeltaBytes() - Method in class io.confluent.kafka.link.LinkContext
 
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

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
 
entries() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecrets
 
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.LogicalClusterMetadata
 
equals(Object) - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
equals(Object) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipal
 
equals(Object) - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
equals(Object) - Method in class io.confluent.kafka.multitenant.SslCertificateSpecification
 
equals(Object) - Method in class io.confluent.kafka.multitenant.TenantMetadata
 
equals(Object) - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
evaluateResponse(byte[]) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
EXTERNAL_LISTENER_PREFIX - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 
extractClusterIdFromHostName(Optional<SNIHostName>) - Static method in class io.confluent.kafka.server.plugins.auth.AuthUtils
Extract the cluster ID from the provided host name, if possible.
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

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
 
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
findRule(KafkaPrincipal, Set<KafkaPrincipal>, KafkaPrincipal, KafkaPrincipal, String, Action) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
fromString(String) - Static method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
 
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

get() - Method in class io.confluent.kafka.multitenant.utils.Optional
 
get(String, String) - Method in class io.confluent.kafka.server.plugins.auth.AuthAttemptCache
Return the hash for the [username, password] if any
get(List<AppConfigurationEntry>, SNIHostName) - Method in interface io.confluent.kafka.server.plugins.auth.SaslServerSupplier
 
getAuthorizationID() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
getBootstrapBrokerForListener(String, Map<String, ?>) - Static method in class io.confluent.common.InterClusterConnection
 
getFailed() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
getFailed() - Method in interface io.confluent.kafka.server.plugins.auth.stats.AuthenticationStatsMBean
 
getInstance(String) - Static method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
getInstance() - Static method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
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
 
getSucceeded() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
getSucceeded() - Method in interface io.confluent.kafka.server.plugins.auth.stats.AuthenticationStatsMBean
 
getSucceeded() - Method in class io.confluent.kafka.server.plugins.auth.stats.TenantAuthenticationStats.TenantAuthStats
 
getSucceeded() - Method in interface io.confluent.kafka.server.plugins.auth.stats.TenantAuthenticationStats.TenantAuthStatsMBean
 
getText() - Method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
 
getTotal() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
getTotal() - Method in interface io.confluent.kafka.server.plugins.auth.stats.AuthenticationStatsMBean
 
GROUP - Static variable in class io.confluent.kafka.multitenant.metrics.TenantMetrics
 

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
 
handleSocketServerInitialized(String) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
hashCode() - Method in class io.confluent.common.EndPoint
 
hashCode() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
hashCode() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
hashCode() - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipal
 
hashCode() - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
hashCode() - Method in class io.confluent.kafka.multitenant.SslCertificateSpecification
 
hashCode() - Method in class io.confluent.kafka.multitenant.TenantMetadata
 
hashCode() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
hashedSecret() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
hashFunction() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
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.LogicalClusterMetadata
 
host() - Method in class io.confluent.common.EndPoint
 

I

inactiveClusters() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
Return all logical clusters that are deactivated
incrFailed() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
incrSucceeded() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
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
 
instance() - Static method in class io.confluent.kafka.server.plugins.auth.stats.TenantAuthenticationStats
 
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.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.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.stats - package io.confluent.kafka.server.plugins.auth.stats
 
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
 
isApiAllowed(ApiKeys) - Static method in class io.confluent.kafka.link.ClusterLinkApis
 
isApiAllowed(ApiKeys) - Static 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
 
isClusterPrefixForHostnameEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
 
isComplete() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
isDefined() - Method in class io.confluent.kafka.multitenant.utils.Optional
 
isExpired(Metrics, Sensor) - Static method in class io.confluent.kafka.multitenant.metrics.TenantMetrics
 
isNewTopic() - Method in class io.confluent.kafka.multitenant.quota.TenantPartitionAssignor.TopicInfo
 
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 - Variable in class io.confluent.kafka.multitenant.TenantMetadata.Builder
 
isSuperUser - Variable in class io.confluent.kafka.multitenant.TenantMetadata
 
isSuperUser(KafkaPrincipal, Scope) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
isTenantPrefixed(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 
isTenantPrincipal(KafkaPrincipal) - Static method in class io.confluent.kafka.multitenant.MultiTenantPrincipal
 
isUp() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
Returns true if cache is loaded and listening for metadata, otherwise returns false.

K

k8sClusterId() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
KAFKA_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 

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.LogicalClusterMetadata
 
LifecycleMetadata(String, String, Date, Date) - Constructor for class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
LINK_HEALTHCHECK_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
LINK_TAG - Static variable in class io.confluent.kafka.link.ClusterLinkInterceptor
 
LinkContext - Class in io.confluent.kafka.link
 
LinkContext(String, String) - Constructor for class io.confluent.kafka.link.LinkContext
 
linkName() - Method in class io.confluent.kafka.link.LinkContext
 
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
 
logicalClusterId() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
logicalClusterId() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
logicalClusterIds() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
Returns all active logical clusters with up-to-date/valid metadata hosted by this physical cluster
logicalClusterIdsIncludingStale() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
Returns all active logical clusters hosted by this physical cluster, including logical clusters with stale/invalid metadata
LogicalClusterMetadata - Class in io.confluent.kafka.multitenant
Represents logical cluster metadata
LogicalClusterMetadata(String, String, String, String, String, String, Long, Long, Long, Long, Long, Long, Integer, LogicalClusterMetadata.LifecycleMetadata) - Constructor for class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
LogicalClusterMetadata.LifecycleMetadata - Class in io.confluent.kafka.multitenant
 
logicalClusterName() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
logicalClusterName() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
logicalClusterType() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
login() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule
 
logout() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule
 

M

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
 
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_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_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
 
maybeAddTransformableType(Field, Type) - Method in interface io.confluent.kafka.multitenant.schema.TransformableSchema.FieldSelector
Optionally return a TransformableType if the field should be transformed.
mayDeny() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
mayDeny() - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
metadata(String) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
Returns metadata of a given logical cluster ID
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.TenantMetricsContext
 
MIN_ISR - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
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
 
MultiTenantApis - Class in io.confluent.kafka.multitenant.schema
A cache of TransformableSchema for Kafka APIs which apply the multi-tenant transformations needed to enforce tenant isolation.
MultiTenantApis() - 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
 
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
 
MultiTenantPrincipal - Class in io.confluent.kafka.multitenant
 
MultiTenantPrincipal(String, TenantMetadata) - Constructor for class io.confluent.kafka.multitenant.MultiTenantPrincipal
 
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, Time, Metrics, TenantMetrics, MultiTenantInterceptorConfig, Optional<ClusterLinkMetrics>) - Constructor for class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
MultiTenantSaslConfigEntry - Class in io.confluent.kafka.server.plugins.auth
 
MultiTenantSaslConfigEntry(String, String, String, String, String, boolean) - Constructor for class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
MultiTenantSaslSecrets - Class in io.confluent.kafka.server.plugins.auth
 
MultiTenantSaslSecrets(Map<String, MultiTenantSaslConfigEntry>) - Constructor for class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecrets
 
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
 
MultiTenantSaslServer - Interface in io.confluent.kafka.multitenant
 

N

networkQuotaOverhead() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
newContext(RequestHeader, String, InetAddress, KafkaPrincipal, ListenerName, SecurityProtocol, ClientInformation, Metrics) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor
 
none() - Static method in class io.confluent.kafka.multitenant.utils.Optional
 
NOT_PROVIDED_MSG - Static variable in class io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator
 
NotTenantPrefixedException(String) - Constructor for exception io.confluent.kafka.multitenant.utils.TenantSanitizer.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
 
onSuccessfulAuthentication(MultiTenantPrincipal) - Method in class io.confluent.kafka.server.plugins.auth.stats.TenantAuthenticationStats
 
operation(AclOperation) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
Optional<T> - Class in io.confluent.kafka.multitenant.utils
 

P

parse(String) - Static method in class io.confluent.common.EndPoint
 
parse(String, Map<ListenerName, SecurityProtocol>) - Static method in class io.confluent.common.EndPoint
 
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, ResponseHeader, RequestHeader, long) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor
 
PARTITION_TAG - Static variable in class io.confluent.kafka.multitenant.metrics.PartitionSensors
 
partitionAssignor() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
 
partitionAssignor(Map<String, ?>) - Static method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
PartitionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics
 
PartitionSensorBuilder(Metrics, TenantMetrics.MetricsRequestContext) - Constructor for class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
PartitionSensorBuilder(Metrics, TenantMetrics.MetricsRequestContext, boolean) - Constructor for class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
PartitionSensors - Class in io.confluent.kafka.multitenant.metrics
 
PartitionSensors(TenantMetrics.MetricsRequestContext, Metrics, Map<String, Sensor>, PartitionSensorBuilder, boolean) - 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.LogicalClusterMetadata
 
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.LogicalClusterMetadata.LifecycleMetadata
 
PLAIN_MECHANISM - Static variable in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
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, SNIHostName) - 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
 
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
 
producerByteRate() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
providerName() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
providerName() - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
PUBLIC_KEY_PATH_KEY - Static variable in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler
 
put(String, String, String) - Method in class io.confluent.kafka.server.plugins.auth.AuthAttemptCache
Cache an authorisation.

Q

quota(ClientQuotaType) - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
quotaConfig() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
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

read(ByteBuffer, T) - Method in class io.confluent.kafka.multitenant.schema.AbstractTransformableType
 
read(ByteBuffer, T) - Method in class io.confluent.kafka.multitenant.schema.TransformableSchema
Read a schema from a buffer, applying transformations given the passed context.
read(ByteBuffer, T) - Method in class io.confluent.kafka.multitenant.schema.TransformableSchema.TransformableTaggedFields
 
read(ByteBuffer, T) - Method in interface io.confluent.kafka.multitenant.schema.TransformableType
 
reconfigurableConfigs() - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
reconfigurableConfigs() - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
recordAuthenticatedConnection() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensors
 
recordAuthenticatedConnection(Metrics, MultiTenantPrincipal) - 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
 
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
 
removeAllMBeans() - Method in class io.confluent.kafka.server.plugins.auth.stats.TenantAuthenticationStats
 
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
 
removeUnusedMBeans(Set<MultiTenantPrincipal>) - Method in class io.confluent.kafka.server.plugins.auth.stats.TenantAuthenticationStats
 
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.quota.TenantPartitionAssignor.TopicInfo
 
requestSchema(ApiKeys, short) - Static method in class io.confluent.kafka.link.ClusterLinkApis
 
requestSchema(ApiKeys, short) - Static method in class io.confluent.kafka.multitenant.schema.MultiTenantApis
 
requireNonEmpty(String, String) - Static method in class io.confluent.kafka.multitenant.utils.Utils
 
reset() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
resolvedAddress() - Method in class io.confluent.common.EndPoint
 
resourceType(ResourceType) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
responseSchema(ApiKeys, short) - Static method in class io.confluent.kafka.link.ClusterLinkApis
 
responseSchema(ApiKeys, short) - Static method in class io.confluent.kafka.multitenant.schema.MultiTenantApis
 
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
 

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
 
saslMechanism() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
SaslServerSupplier - Interface in io.confluent.kafka.server.plugins.auth
 
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.ConnectionSensorBuilder
 
sensorCreators() - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
sensorSuffix(String, TenantMetrics.TenantMetricsContext) - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensorBuilder
 
sensorSuffix(String, TenantMetrics.MetricsRequestContext) - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext
 
serviceAccount() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
shouldIntercept() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
sizeOf(Object, T) - Method in class io.confluent.kafka.multitenant.schema.AbstractTransformableType
 
sizeOf(Object, T) - Method in class io.confluent.kafka.multitenant.schema.TransformableSchema
Get the serialized size in bytes of an object after transformations have been applied given the passed context.
sizeOf(Object, T) - Method in class io.confluent.kafka.multitenant.schema.TransformableSchema.TransformableTaggedFields
 
sizeOf(Object, T) - Method in interface io.confluent.kafka.multitenant.schema.TransformableType
 
sizeOfRemovedPrefixes(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
SNI_HOST_NAME_KEY - Static variable in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler
 
SNI_HOST_NAME_VALIDATION_MODE_KEY - Static variable in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
 
sniHostNameMatches(String, Optional<String>, Optional<SNIHostName>) - 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.
some(T) - Static method in class io.confluent.kafka.multitenant.utils.Optional
 
sourceToDest(String) - Method in class io.confluent.kafka.link.LinkContext
 
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
 
SslCertificateSpecification - Class in io.confluent.kafka.multitenant
Represents specifications for ssl certificates - pem and pkcs
start(AuthorizerServerInfo) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
start(AuthorizerServerInfo) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
status() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
storageBytes() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
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.
superUser(boolean) - Method in class io.confluent.kafka.multitenant.TenantMetadata.Builder
 

T

TENANT_TAG - Static variable in class io.confluent.kafka.multitenant.metrics.TenantMetrics
 
TENANT_USER_TYPE - Static variable in class io.confluent.kafka.multitenant.MultiTenantPrincipal
 
TENANT_WILDCARD_USER_TYPE - Static variable in class io.confluent.kafka.multitenant.MultiTenantPrincipal
 
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) - Static method in class io.confluent.kafka.multitenant.utils.TenantSanitizer
 
TenantAuthenticationStats - Class in io.confluent.kafka.server.plugins.auth.stats
 
TenantAuthenticationStats() - Constructor for class io.confluent.kafka.server.plugins.auth.stats.TenantAuthenticationStats
 
TenantAuthenticationStats.TenantAuthStats - Class in io.confluent.kafka.server.plugins.auth.stats
 
TenantAuthenticationStats.TenantAuthStatsMBean - Interface in io.confluent.kafka.server.plugins.auth.stats
 
TenantAuthStats() - Constructor for class io.confluent.kafka.server.plugins.auth.stats.TenantAuthenticationStats.TenantAuthStats
 
TenantContext - Class in io.confluent.kafka.multitenant.schema
 
TenantContext(MultiTenantPrincipal) - Constructor for class io.confluent.kafka.multitenant.schema.TenantContext
 
TenantContext.ValueType - Enum in io.confluent.kafka.multitenant.schema
 
tenantLifecycleManager - Variable in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
TenantLifecycleManager - Class in io.confluent.kafka.multitenant
 
TenantLifecycleManager(Map<String, ?>) - Constructor for class io.confluent.kafka.multitenant.TenantLifecycleManager
 
tenantMetadata() - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipal
 
tenantMetadata() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer
 
TenantMetadata - Class in io.confluent.kafka.multitenant
 
TenantMetadata(String, String) - Constructor for class io.confluent.kafka.multitenant.TenantMetadata
 
tenantMetadata() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
TenantMetadata.Builder - Class in io.confluent.kafka.multitenant
 
TenantMetrics - Class in io.confluent.kafka.multitenant.metrics
 
TenantMetrics() - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics
 
TenantMetrics.MetricsRequestContext - 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
 
tenantName - Variable in class io.confluent.kafka.multitenant.TenantMetadata.Builder
 
tenantName - Variable in class io.confluent.kafka.multitenant.TenantMetadata
 
TenantPartitionAssignor - Class in io.confluent.kafka.multitenant.quota
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() - Constructor for class io.confluent.kafka.multitenant.quota.TenantPartitionAssignor
 
TenantPartitionAssignor.TopicInfo - Class in io.confluent.kafka.multitenant.quota
Topic details from new topic or partition create request.
tenantPrefix() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
tenantPrefix() - Method in class io.confluent.kafka.multitenant.TenantMetadata
 
TenantQuotaCallback - Class in io.confluent.kafka.multitenant.quota
 
TenantQuotaCallback() - Constructor for class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
TenantSanitizer - Class in io.confluent.kafka.multitenant.utils
These functions transform various pieces of internal information to remove internal implementation details.
TenantSanitizer() - Constructor for class io.confluent.kafka.multitenant.utils.TenantSanitizer
 
TenantSanitizer.NotTenantPrefixedException - Exception in io.confluent.kafka.multitenant.utils
 
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
 
TOPIC_TAG - Static variable in class io.confluent.kafka.multitenant.metrics.PartitionSensors
 
TopicInfo(int, short, int) - Constructor for class io.confluent.kafka.multitenant.quota.TenantPartitionAssignor.TopicInfo
 
topicMetadataUpdated(Collection<TopicPartition>) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
TopicPolicyConfig - Class in io.confluent.kafka.server.plugins.policy
 
TopicPolicyConfig(Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
toSend(RequestHeader, AbstractRequest, String) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor
 
toString() - Method in class io.confluent.common.EndPoint
 
toString() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
toString() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
toString() - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipal
 
toString() - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
toString() - Method in class io.confluent.kafka.multitenant.TenantMetadata
 
toString() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
toString() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
totalPartitions() - Method in class io.confluent.kafka.multitenant.quota.TenantPartitionAssignor.TopicInfo
 
transform(Object, T) - Method in class io.confluent.kafka.multitenant.schema.AbstractTransformableType
 
TransformableSchema<T extends TransformContext> - Class in io.confluent.kafka.multitenant.schema
TransformableSchema provides a way to embed field transformations into an existing Schema.
TransformableSchema(Schema, TransformableSchema.TransformableField<T>[]) - Constructor for class io.confluent.kafka.multitenant.schema.TransformableSchema
 
TransformableSchema.FieldSelector<T extends TransformContext> - Interface in io.confluent.kafka.multitenant.schema
This interface is used to select the fields for transformation and to install the transformer itself into the TransformableSchema.
TransformableSchema.TransformableTaggedFields<T extends TransformContext> - Class in io.confluent.kafka.multitenant.schema
 
TransformableTaggedFields(Map<Integer, TransformableType<T>>) - Constructor for class io.confluent.kafka.multitenant.schema.TransformableSchema.TransformableTaggedFields
 
TransformableType<T extends TransformContext> - Interface in io.confluent.kafka.multitenant.schema
 
TransformContext - Interface in io.confluent.kafka.multitenant.schema
 
transformSchema(Schema, TransformableSchema.FieldSelector<T>) - Static method in class io.confluent.kafka.multitenant.schema.TransformableSchema
 
type - Variable in class io.confluent.kafka.multitenant.schema.AbstractTransformableType
 
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
 
UPDATABLE_TOPIC_CONFIGS - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 
updateClusterMetadata(Cluster) - Method in class io.confluent.kafka.multitenant.quota.TenantPartitionAssignor
 
updateClusterMetadata(Cluster) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
Handle metadata update.
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.
updateTenantState(LogicalClusterMetadata) - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
 
user() - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipal
 
userId() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
userIdentifier() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer
 
userIdentifier() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
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
 
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(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.quota.TenantQuotaCallback
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
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.schema.TenantContext.ValueType
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.schema.TenantContext.ValueType
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) - Static method in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 

W

wrap(byte[], int, int) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
write(ByteBuffer, Object, T) - Method in class io.confluent.kafka.multitenant.schema.AbstractTransformableType
 
write(ByteBuffer, Object, T) - Method in class io.confluent.kafka.multitenant.schema.TransformableSchema.TransformableTaggedFields
 
write(ByteBuffer, Object, T) - Method in class io.confluent.kafka.multitenant.schema.TransformableSchema
Transform and serialize an object to a buffer given the passed context.
write(ByteBuffer, Object, T) - Method in interface io.confluent.kafka.multitenant.schema.TransformableType
 
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
 

Z

zkAclProvider() - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
A B C D E F G H I K L M N O P Q R S T U V W Z 
Skip navigation links