Index (ce-auth-providers 8.2.1-ce API)

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

A

AbstractAuthCache - Class in io.confluent.security.auth.store.cache: Cache containing authorization and authentication metadata.
AbstractAuthCache(RbacRoles, Scope, AccessRuleStore, AccessRuleStore) - Constructor for class io.confluent.security.auth.store.cache.AbstractAuthCache
AccessRuleStore - Interface in io.confluent.security.auth.store.cache
accountId() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
ACL_ACCESS_RULES_COUNT - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics
aclBindings(Scope, AclBindingFilter, Predicate<ResourcePattern>) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
aclRules(Scope) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
acls(AclBindingFilter) - Method in class io.confluent.security.auth.provider.AuthnzProvider
acls(AclBindingFilter) - Method in class io.confluent.security.auth.provider.ConfluentProvider
activeNodeUrls(String) - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
activeNodeUrls(String) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
activeNodeUrls(String) - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
activeNodeUrls(String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
activeNodeUrls(String) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
add(Scope, KafkaPrincipal, Map<ResourcePattern, Set<AccessRule>>) - Method in interface io.confluent.security.auth.store.cache.AccessRuleStore
add(Scope, KafkaPrincipal, Map<ResourcePattern, Set<AccessRule>>) - Method in class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
add(Scope, KafkaPrincipal, Map<ResourcePattern, Set<AccessRule>>) - Method in class io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore
addCertificates(String, String, X509Certificate[]) - Method in class io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager
addClusterRoleBinding(Optional<KafkaPrincipal>, KafkaPrincipal, String, Scope, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
addClusterRoleBinding(Optional<KafkaPrincipal>, KafkaPrincipal, String, Scope, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
addIdentityPool(Optional<Principal>, String, int, String, String, String, String, String, String, String, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
addIdentityPool(Optional<Principal>, String, int, String, String, String, String, String, String, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
addIdentityProvider(Optional<Principal>, String, String, String, String, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
addIdentityProvider(Optional<Principal>, String, String, String, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
addJwks(Optional<Principal>, String, String, JsonWebKeySet, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
addJwks(Optional<Principal>, String, String, JsonWebKeySet, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
addMatchingRule(ResourceAuthorizeRules, Scope, String, Operation, ResourceType) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
addMatchingRules(ResourceAuthorizeRules, Scope, Set<KafkaPrincipal>, String, Operation, ResourceType) - Method in interface io.confluent.security.auth.store.cache.AccessRuleStore
addMatchingRules(ResourceAuthorizeRules, Scope, Set<KafkaPrincipal>, String, Operation, ResourceType) - Method in class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
addMatchingRules(ResourceAuthorizeRules, Scope, Set<KafkaPrincipal>, String, Operation, ResourceType) - Method in class io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore
addMatchingRules(ResourceAuthorizeRules, KafkaPrincipal, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
addMatchingRules(ResourceAuthorizeRules, KafkaPrincipal, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
addMatchingRules(ResourceAuthorizeRules, KafkaPrincipal, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in class io.confluent.security.auth.provider.AuthnzProvider
addMatchingRules(ResourceAuthorizeRules, KafkaPrincipal, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in class io.confluent.security.auth.provider.ConfluentProvider
addMatchingRules(ResourceAuthorizeRules, KafkaPrincipal, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
addRefreshTokenInfo(Optional<Principal>, String, String, long, String, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
addRefreshTokenInfo(Optional<Principal>, String, String, long, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
addResourceRoleBinding(Optional<KafkaPrincipal>, KafkaPrincipal, String, Scope, Collection<ResourcePattern>, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
addResourceRoleBinding(Optional<KafkaPrincipal>, KafkaPrincipal, String, Scope, Collection<ResourcePattern>, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
adminClientConfigs() - Method in class io.confluent.security.store.kafka.KafkaStoreConfig
ALIAS_SEPARATOR - Static variable in class io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager
ALLOW_READER_TO_CREATE_AUTH_TOPIC - Static variable in class io.confluent.security.store.kafka.KafkaStoreConfig
asAuthorizer() - Method in class io.confluent.security.auth.provider.ConfluentProvider
auditLogProvider(AuditLogProvider) - Method in class io.confluent.security.auth.provider.ConfluentProvider
AUTH_TOPIC - Static variable in class io.confluent.security.auth.store.kafka.KafkaAuthStore
authCache() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
authCache() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
authCache() - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
authCache() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
AuthnzAuthStore - Class in io.confluent.security.auth.dataplane
AuthnzAuthStore(Scope, Metrics) - Constructor for class io.confluent.security.auth.dataplane.AuthnzAuthStore
AuthnzAuthStore(RbacRoles, Time, Scope, Metrics, int) - Constructor for class io.confluent.security.auth.dataplane.AuthnzAuthStore
AuthnzMultiTenantSaslSecretsStore - Class in io.confluent.security.auth.dataplane
AuthnzMultiTenantSaslSecretsStore(Map<String, Object>, Metrics) - Constructor for class io.confluent.security.auth.dataplane.AuthnzMultiTenantSaslSecretsStore
AuthnzProvider - Class in io.confluent.security.auth.provider
AuthnzProvider() - Constructor for class io.confluent.security.auth.provider.AuthnzProvider
AuthnzServerAuthorizer - Class in io.confluent.security.auth.dataplane: Cross-component embedded authorizer that implements common authorization logic.
AuthnzServerAuthorizer() - Constructor for class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer
AuthnzServerAuthorizer.AuthnzServerInfo - Class in io.confluent.security.auth.dataplane
AuthnzServerInfo(Metrics) - Constructor for class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer.AuthnzServerInfo
AuthnzTopicBasedPhysicalClusterMetadata - Class in io.confluent.security.auth.dataplane: This holds metadata passed from CCloud related to this physical cluster
AuthnzTopicBasedPhysicalClusterMetadata(Metrics) - Constructor for class io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
AuthnzTopicBasedPhysicalClusterMetadata(Metrics, Time) - Constructor for class io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
authorize(AuthorizableRequestContext, List<Action>) - Method in class io.confluent.security.auth.provider.AuthnzProvider
authorize(AuthorizableRequestContext, List<Action>) - Method in class io.confluent.security.auth.provider.ConfluentProvider
authStore() - Method in class io.confluent.security.auth.provider.AuthnzProvider
authStore() - Method in class io.confluent.security.auth.provider.ConfluentProvider
AuthStoreMetrics - Class in io.confluent.security.auth.utils
AuthStoreMetrics(Metrics, AbstractAuthCache) - Constructor for class io.confluent.security.auth.utils.AuthStoreMetrics
authStoreScope() - Method in class io.confluent.security.auth.dataplane.DataplaneProvider: Set Scope.ROOT_SCOPE as we can have multiple lkcs in MT Cluster
authStoreScope() - Method in class io.confluent.security.auth.provider.AuthnzProvider
authStoreScope() - Method in class io.confluent.security.auth.provider.ConfluentProvider
AuthWriterUtils - Class in io.confluent.security.auth.utils: These util methods are used in KafkaAuthWriter and DbAuthWriter (metadata-service repo) projects
AuthWriterUtils() - Constructor for class io.confluent.security.auth.utils.AuthWriterUtils

B

backingLogicalKafkaClusterId() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
BackOffDecorator(Duration, int) - Constructor for class io.confluent.security.auth.store.kafka.KafkaAuthStore.BackOffDecorator
backoffMs(int) - Method in class io.confluent.security.auth.utils.RetryBackoff
BOOTSTRAP_SERVERS_PROP - Static variable in class io.confluent.security.store.kafka.KafkaStoreConfig
brokerId - Variable in class io.confluent.security.store.kafka.KafkaStoreConfig
brokerId() - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer.AuthnzServerInfo
buildCertChain(Certificate[], Map<String, Set<Certificate>>) - Static method in class io.confluent.security.auth.mtls.CaCertificatesUtils: Builds a complete certificate chain from the given client certificate chain, and CA certificates for all providers.

C

caCertificatesCount() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
CaCertificatesUtils - Class in io.confluent.security.auth.mtls
CachedRecord<K,V> - Class in io.confluent.security.store.kafka.clients
certIdentityPoolsCount() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
cidrs() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAccessRule
close() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore
close() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
close() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
close() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
close() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
close() - Method in class io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager
close() - Method in class io.confluent.security.auth.provider.AuthnzProvider
close() - Method in class io.confluent.security.auth.provider.ConfluentProvider
close() - Method in class io.confluent.security.auth.provider.ldap.LdapAuthenticateCallbackHandler
close() - Method in class io.confluent.security.auth.provider.ldap.LdapGroupManager
close() - Method in class io.confluent.security.auth.provider.ldap.LdapGroupProvider
close() - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
close() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore.BackOffDecorator
close() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
close() - Method in class io.confluent.security.store.kafka.clients.JsonSerde
close(Duration) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthReader
close(Duration) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
close(Duration) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
close(Duration) - Method in class io.confluent.security.store.kafka.clients.KafkaReader
close(Duration) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
CloudAuthCache - Class in io.confluent.security.auth.cloud
CloudAuthCache(RbacRoles, Scope) - Constructor for class io.confluent.security.auth.cloud.CloudAuthCache
CloudAuthCache(RbacRoles, Scope, ScopePrincipalAccessRuleStore, ScopePrincipalAccessRuleStore) - Constructor for class io.confluent.security.auth.cloud.CloudAuthCache
clusterResource() - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer.AuthnzServerInfo
compareTo(NodeMetadata) - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
completeInitialLoad() - Method in class io.confluent.security.auth.provider.ConfluentProvider
CONFIG_PREFIX - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
ConfigurableSslSocketFactory - Class in io.confluent.security.auth.utils
configure(Map<String, ?>) - Method in class io.confluent.security.auth.dataplane.AuthnzAuthStore
configure(Map<String, ?>) - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer
configure(Map<String, ?>) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore
configure(Map<String, ?>) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
configure(Map<String, ?>) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
configure(Map<String, ?>) - Method in class io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager
configure(Map<String, ?>) - Method in class io.confluent.security.auth.provider.AuthnzProvider
configure(Map<String, ?>) - Method in class io.confluent.security.auth.provider.ConfluentProvider
configure(Map<String, ?>) - Method in class io.confluent.security.auth.provider.ldap.LdapGroupProvider
configure(Map<String, ?>) - Method in class io.confluent.security.auth.provider.ldap.LdapStore
configure(Map<String, ?>) - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
configure(Map<String, ?>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
configure(Map<String, ?>) - Method in class io.confluent.security.store.kafka.clients.JsonSerde
configure(Map<String, ?>, boolean) - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde
configure(Map<String, ?>, boolean) - Method in class io.confluent.security.store.kafka.clients.JsonSerde
configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.security.auth.provider.ldap.LdapAuthenticateCallbackHandler
configureServerInfo(ConfluentAuthorizerServerInfo) - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer
ConfluentProvider - Class in io.confluent.security.auth.provider
ConfluentProvider() - Constructor for class io.confluent.security.auth.provider.ConfluentProvider
consumerConfigs(String) - Method in class io.confluent.security.store.kafka.KafkaStoreConfig
ConsumerListener<K,V> - Interface in io.confluent.security.store.kafka.clients
coordinatorConfigs() - Method in class io.confluent.security.store.kafka.KafkaStoreConfig
createAcls(Optional<KafkaPrincipal>, Scope, List<AclBinding>) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
createAcls(Optional<KafkaPrincipal>, Scope, List<AclBinding>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
createAcls(Optional<KafkaPrincipal>, Scope, AclBinding) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
createAcls(Optional<KafkaPrincipal>, Scope, AclBinding) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
createAcls(AuthorizableRequestContext, List<AclBinding>) - Method in class io.confluent.security.auth.provider.AuthnzProvider
createAcls(AuthorizableRequestContext, List<AclBinding>) - Method in class io.confluent.security.auth.provider.ConfluentProvider
createAcls(AuthorizableRequestContext, List<AclBinding>, Optional<String>) - Method in class io.confluent.security.auth.provider.AuthnzProvider
createAcls(AuthorizableRequestContext, List<AclBinding>, Optional<String>) - Method in class io.confluent.security.auth.provider.ConfluentProvider
createLdapContext() - Method in class io.confluent.security.auth.provider.ldap.LdapContextCreator
createRbacAuthorizer() - Method in class io.confluent.security.auth.provider.ConfluentProvider
creationDate() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata

D

DataplaneAuthReader<K,V> - Class in io.confluent.security.auth.dataplane
DataplaneAuthReader(String, int, Future<Consumer<K, V>>, KeyValueStore<K, V>, ConsumerListener<K, V>, StatusListener, KafkaStoreConfig, Time) - Constructor for class io.confluent.security.auth.dataplane.DataplaneAuthReader
DataplaneAuthReader(String, int, Future<Consumer<K, V>>, KeyValueStore<K, V>, ConsumerListener<K, V>, StatusListener, KafkaStoreConfig, Time, Meter) - Constructor for class io.confluent.security.auth.dataplane.DataplaneAuthReader
DataplaneAuthStore - Class in io.confluent.security.auth.dataplane
DataplaneAuthStore(Scope, ConfluentAuthorizerServerInfo) - Constructor for class io.confluent.security.auth.dataplane.DataplaneAuthStore
DataplaneAuthStore(RbacRoles, Time, Scope, ConfluentAuthorizerServerInfo, int) - Constructor for class io.confluent.security.auth.dataplane.DataplaneAuthStore
DataplaneAuthWriter - Class in io.confluent.security.auth.dataplane
DataplaneAuthWriter() - Constructor for class io.confluent.security.auth.dataplane.DataplaneAuthWriter
DataplaneBaseAuthStore - Class in io.confluent.security.auth.dataplane
DataplaneBaseAuthStore.DeserializerErrorForKey - Class in io.confluent.security.auth.dataplane
DataplaneBaseAuthStore.DeserializerErrorForValue - Class in io.confluent.security.auth.dataplane
DataplaneProvider - Class in io.confluent.security.auth.dataplane
DataplaneProvider() - Constructor for class io.confluent.security.auth.dataplane.DataplaneProvider
dedicatedLogicalClusterId() - Method in class io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
DEFAULT - Enum constant in enum class io.confluent.security.auth.provider.ldap.LdapPrincipalMapping
DefaultAuthCache - Class in io.confluent.security.auth.store.cache
DefaultAuthCache(RbacRoles, Scope) - Constructor for class io.confluent.security.auth.store.cache.DefaultAuthCache
DefaultAuthCache(RbacRoles, Scope, ScopeAccessRuleStore, ScopeAccessRuleStore) - Constructor for class io.confluent.security.auth.store.cache.DefaultAuthCache
DefaultMTlsTruststoreManager - Class in io.confluent.security.auth.mtls: Default implementation of MTlsTruststoreManager that manages CA certificates in a truststore file.
DefaultMTlsTruststoreManager() - Constructor for class io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager
delete(K) - Method in interface io.confluent.security.auth.store.external.ExternalStoreListener: Invoked when a refresh of the external store indicates that an entry was deleted.
deleteAcls(Optional<KafkaPrincipal>, Scope, List<AclBindingFilter>, Predicate<ResourcePattern>) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
deleteAcls(Optional<KafkaPrincipal>, Scope, List<AclBindingFilter>, Predicate<ResourcePattern>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
deleteAcls(Optional<KafkaPrincipal>, Scope, AclBindingFilter, Predicate<ResourcePattern>) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
deleteAcls(Optional<KafkaPrincipal>, Scope, AclBindingFilter, Predicate<ResourcePattern>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>) - Method in class io.confluent.security.auth.provider.AuthnzProvider
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>) - Method in class io.confluent.security.auth.provider.ConfluentProvider
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>, Optional<String>, AclState) - Method in class io.confluent.security.auth.provider.AuthnzProvider
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>, Optional<String>, AclState) - Method in class io.confluent.security.auth.provider.ConfluentProvider
deletionDate() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
DeserializationError(Headers, byte[], boolean, Exception) - Constructor for class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde.DeserializationError
DeserializationErrorHandlingJsonSerde<T> - Class in io.confluent.security.store.kafka.clients: ErrorHandlingJsonSerde that catches exceptions while deserializing key/value of the records and returns the value as per the user provided handleDeserializationExceptionFunction
DeserializationErrorHandlingJsonSerde.DeserializationError - Class in io.confluent.security.store.kafka.clients
deserialize(String, byte[]) - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde
deserialize(String, byte[]) - Method in class io.confluent.security.store.kafka.clients.JsonSerde
deserialize(String, Headers, byte[]) - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde
deserialize(ByteBuffer) - Static method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
deserializer() - Method in class io.confluent.security.store.kafka.clients.JsonSerde
DeserializerErrorForKey(DeserializationErrorHandlingJsonSerde.DeserializationError) - Constructor for class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.DeserializerErrorForKey
DeserializerErrorForValue(DeserializationErrorHandlingJsonSerde.DeserializationError) - Constructor for class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.DeserializerErrorForValue
DryRunIpFilteringProvider - Class in io.confluent.security.auth.ipFiltering: This class is a dry run implementation of the IpFilteringProvider.
DryRunIpFilteringProvider() - Constructor for class io.confluent.security.auth.ipFiltering.DryRunIpFilteringProvider
DUPLICATE_URLS - Enum constant in enum class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment.AssignmentError

E

earlyStartListeners() - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer.AuthnzServerInfo
elapsedSeconds(Time, long) - Static method in class io.confluent.security.auth.utils.MetricsUtils
endpoints() - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer.AuthnzServerInfo
entryType() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.DeserializerErrorForKey
entryType() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.DeserializerErrorForValue
environmentId() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
equals(Object) - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
equals(Object) - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
error() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.DeserializerErrorForKey
error() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.DeserializerErrorForValue
error() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
errorCode() - Method in enum class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment.AssignmentError
existingRecordsFuture() - Method in class io.confluent.security.store.kafka.clients.KafkaReader: Returns future that completes when existing records on all partitions at the time the KafkaReader was started are processed and available in the cache.
existingRecordsFuture(TopicPartition) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthReader
ExternalKafkaAuthStore - Class in io.confluent.security.auth.store.kafka
ExternalKafkaAuthStore(Scope, ConfluentAuthorizerServerInfo) - Constructor for class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
ExternalKafkaAuthStore(Scope, ConfluentAuthorizerServerInfo, RbacRoles) - Constructor for class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
ExternalStore - Interface in io.confluent.security.auth.store.external: Interface for managing metadata from an external store, for example an LDAP server.
ExternalStoreListener<K,V> - Interface in io.confluent.security.auth.store.external: Listener for entries from an external store, for example an LDAP server.

F

fail(int, String) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
fail(int, String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
fail(String) - Method in interface io.confluent.security.auth.store.external.ExternalStoreListener: Indicates that the connection to the external store has failed.
failed() - Method in class io.confluent.security.auth.provider.ldap.LdapGroupManager
failed() - Method in class io.confluent.security.auth.provider.ldap.LdapStore
failed() - Method in interface io.confluent.security.auth.store.external.ExternalStore: Returns true if the external store has failed and retries have timed out.
file() - Method in class io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager
findCertIdentityPools(X509Certificate, String, String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
findCertIdentityPools(Map<String, String>, String, String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
findCertIdentityProviders(Certificate[], String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
findIdentityPools(String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
findIdentityProviderIds(String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
findMatchingRule(Set<KafkaPrincipal>, String, Action) - Method in interface io.confluent.security.auth.store.cache.AccessRuleStore
findMatchingRule(Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
findMatchingRule(Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore
findRule(String, Action) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.security.auth.cloud.CloudAuthCache
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.security.auth.ipFiltering.DryRunIpFilteringProvider
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.security.auth.provider.AuthnzProvider
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.security.auth.provider.ConfluentProvider
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
findSigningCert(Certificate, Collection<Certificate>) - Static method in class io.confluent.security.auth.mtls.CaCertificatesUtils: Find signing cert of a given certificate in a collection of certificates.
fromProtobuf(LogicalCluster) - Static method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata

G

generateUniqueAlias(X509Certificate, String, String) - Static method in class io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager
generationIdDuringRead() - Method in class io.confluent.security.store.kafka.clients.CachedRecord
get(AuthKey) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
get(AuthKey) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
get(Scope) - Method in interface io.confluent.security.auth.store.cache.AccessRuleStore
get(Scope) - Method in class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
get(Scope) - Method in class io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore
getCertChain(Certificate[], String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
getData() - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde.DeserializationError
getDefault() - Static method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
getException() - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde.DeserializationError
getHeaders() - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde.DeserializationError
getOrgToCaCertMapping() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
GROUP_AUTHORIZATION_ENABLED_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_AUTHORIZATION_ENABLED_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_AUTHORIZATION_ENABLED_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_DN_NAME_PATTERN_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_DN_NAME_PATTERN_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_DN_NAME_PATTERN_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_MEMBER_ATTRIBUTE_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_MEMBER_ATTRIBUTE_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_MEMBER_ATTRIBUTE_PATTERN_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_MEMBER_ATTRIBUTE_PATTERN_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_MEMBER_ATTRIBUTE_PATTERN_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_MEMBER_ATTRIBUTE_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_NAME - Static variable in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStoreMetrics
GROUP_NAME - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics
GROUP_NAME_ATTRIBUTE_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_NAME_ATTRIBUTE_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_NAME_ATTRIBUTE_PATTERN_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_NAME_ATTRIBUTE_PATTERN_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_NAME_ATTRIBUTE_PATTERN_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_NAME_ATTRIBUTE_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_OBJECT_CLASS_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_OBJECT_CLASS_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_OBJECT_CLASS_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_SEARCH_BASE_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_SEARCH_BASE_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_SEARCH_BASE_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_SEARCH_FILTER_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_SEARCH_FILTER_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_SEARCH_FILTER_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_SEARCH_SCOPE_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_SEARCH_SCOPE_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
GROUP_SEARCH_SCOPE_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
groups(String) - Method in class io.confluent.security.auth.provider.ldap.LdapGroupManager
groups(KafkaPrincipal) - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
groups(KafkaPrincipal) - Method in class io.confluent.security.auth.provider.ConfluentProvider
groups(KafkaPrincipal) - Method in class io.confluent.security.auth.provider.ldap.LdapGroupProvider
groups(KafkaPrincipal) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache: Returns the groups of the provided user principal.
GROUPS - Enum constant in enum class io.confluent.security.auth.provider.ldap.LdapConfig.SearchMode

H

handle(Callback[]) - Method in class io.confluent.security.auth.provider.ldap.LdapAuthenticateCallbackHandler
hashCode() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
hashCode() - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
healthcheck() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache

I

IDENTITY_POOL_COUNT - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics
identityPool(String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
identityPools() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
identityProvider(String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
IGNORE_PARTIAL_RESULT_EXCEPTION - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
IGNORE_PARTIAL_RESULT_EXCEPTION_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
incrementalUpdateFuture() - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter
initialize(Map<K, V>) - Method in interface io.confluent.security.auth.store.external.ExternalStoreListener: Invoked when existing entries from the external store are processed.
interBrokerClientConfig() - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer.AuthnzServerInfo
interBrokerEndpoint() - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer.AuthnzServerInfo
io.confluent.kafka.multitenant - package io.confluent.kafka.multitenant
io.confluent.security.auth.cloud - package io.confluent.security.auth.cloud
io.confluent.security.auth.dataplane - package io.confluent.security.auth.dataplane
io.confluent.security.auth.ipFiltering - package io.confluent.security.auth.ipFiltering
io.confluent.security.auth.metadata - package io.confluent.security.auth.metadata
io.confluent.security.auth.mtls - package io.confluent.security.auth.mtls
io.confluent.security.auth.provider - package io.confluent.security.auth.provider
io.confluent.security.auth.provider.ldap - package io.confluent.security.auth.provider.ldap
io.confluent.security.auth.store.cache - package io.confluent.security.auth.store.cache
io.confluent.security.auth.store.external - package io.confluent.security.auth.store.external
io.confluent.security.auth.store.kafka - package io.confluent.security.auth.store.kafka
io.confluent.security.auth.utils - package io.confluent.security.auth.utils
io.confluent.security.store - package io.confluent.security.store
io.confluent.security.store.kafka - package io.confluent.security.store.kafka
io.confluent.security.store.kafka.clients - package io.confluent.security.store.kafka.clients
io.confluent.security.store.kafka.coordinator - package io.confluent.security.store.kafka.coordinator
IP_FILTERING_ACCESS_RULE_COUNT - Static variable in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStoreMetrics
IP_FILTERING_COUNT - Static variable in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStoreMetrics
IpFilteringAccessRule - Class in io.confluent.security.auth.ipFiltering
IpFilteringAccessRule(String, Collection<String>, Scope) - Constructor for class io.confluent.security.auth.ipFiltering.IpFilteringAccessRule
ipFilteringAuthCache() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
ipFilteringAuthCache() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
IpFilteringAuthCache - Class in io.confluent.security.auth.ipFiltering
IpFilteringAuthCache(IpfOperationGroupDefinitions) - Constructor for class io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
IpFilteringAuthStore - Class in io.confluent.security.auth.ipFiltering
IpFilteringAuthStore(ConfluentAuthorizerServerInfo) - Constructor for class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
IpFilteringAuthStore(ConfluentAuthorizerServerInfo, Time, int) - Constructor for class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
IpFilteringAuthStoreMetrics - Class in io.confluent.security.auth.ipFiltering
IpFilteringAuthStoreMetrics(Metrics, IpFilteringAuthCache) - Constructor for class io.confluent.security.auth.ipFiltering.IpFilteringAuthStoreMetrics
IpFilteringProvider - Class in io.confluent.security.auth.ipFiltering
IpFilteringProvider() - Constructor for class io.confluent.security.auth.ipFiltering.IpFilteringProvider
IpFilteringUtils - Class in io.confluent.security.auth.ipFiltering
IpFilteringUtils() - Constructor for class io.confluent.security.auth.ipFiltering.IpFilteringUtils
isActive() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
isCertificateAuthority(X509Certificate) - Static method in class io.confluent.security.auth.mtls.CaCertificatesUtils: Whether the certificate is a CA certificate
isCompleteCertChain(Certificate[], String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
isForKey() - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde.DeserializationError
isHealthcheckLogicalCluster() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
isIpInCidr(String, String) - Static method in class io.confluent.security.auth.ipFiltering.IpFilteringUtils
isMasterWriter() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
isMasterWriter() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
isMasterWriter() - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
isMasterWriter() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
isMasterWriter() - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
isRevoked(Certificate[], String, String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
isRevoked(X509Certificate, String, String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
isSelfSigned(Certificate) - Static method in class io.confluent.security.auth.mtls.CaCertificatesUtils: checks if the given Certificate is self-signed.
isStarted() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
isSuperUser(KafkaPrincipal, Scope) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
isSuperUser(KafkaPrincipal, Scope) - Method in class io.confluent.security.auth.provider.AuthnzProvider
isSuperUser(KafkaPrincipal, Scope) - Method in class io.confluent.security.auth.provider.ConfluentProvider
isUp() - Method in class io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
isValid() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata: Returns true if metadata values are valid

J

jaasContext(Password, String) - Static method in class io.confluent.security.auth.provider.ldap.LdapContextCreator
JAVA_NAMING_SOCKET_FACTORY_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
JNDI_CONNECT_TIMEOUT_MS_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
JNDI_READ_TIMEOUT_MS_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
JNDI_READ_TIMEOUT_MS_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
JsonSerde<T> - Class in io.confluent.security.store.kafka.clients
JsonSerde(Class<T>) - Constructor for class io.confluent.security.store.kafka.clients.JsonSerde
jsonWebKeySet(String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
jsonWebKeySets() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
JWT_ISSUER_COUNT - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics

K

k8sClusterId() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
KafkaAuthStore - Class in io.confluent.security.auth.store.kafka
KafkaAuthStore(boolean, Scope, ConfluentAuthorizerServerInfo, boolean) - Constructor for class io.confluent.security.auth.store.kafka.KafkaAuthStore
KafkaAuthStore(RbacRoles, Time, Scope, ConfluentAuthorizerServerInfo, int, boolean) - Constructor for class io.confluent.security.auth.store.kafka.KafkaAuthStore
KafkaAuthStore.BackOffDecorator<T> - Class in io.confluent.security.auth.store.kafka
KafkaAuthWriter - Class in io.confluent.security.auth.store.kafka: Writer that initiates updates to metadata.
KafkaAuthWriter(String, int, KafkaStoreConfig, Producer<AuthKey, AuthValue>, Supplier<AdminClient>, AbstractAuthCache, StatusListener, CompletableFuture<Void>, Time) - Constructor for class io.confluent.security.auth.store.kafka.KafkaAuthWriter
kafkaLogicalClusterIds() - Method in class io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
KafkaPartitionWriter<K,V> - Class in io.confluent.security.store.kafka.clients: Writer for one metadata topic partition that encapsulates all the state associated with the partition including master writer generation.
KafkaPartitionWriter(TopicPartition, Producer<K, V>, KeyValueStore<K, V>, MetadataServiceRebalanceListener, StatusListener, Duration, Time) - Constructor for class io.confluent.security.store.kafka.clients.KafkaPartitionWriter
KafkaReader<K,V> - Class in io.confluent.security.store.kafka.clients
KafkaReader(String, int, Future<Consumer<K, V>>, KeyValueStore<K, V>, ConsumerListener<K, V>, StatusListener, KafkaStoreConfig, Time) - Constructor for class io.confluent.security.store.kafka.clients.KafkaReader
KafkaStoreConfig - Class in io.confluent.security.store.kafka
KafkaStoreConfig(int, Map<?, ?>) - Constructor for class io.confluent.security.store.kafka.KafkaStoreConfig
KafkaStoreConfig(AuthorizerServerInfo, Map<?, ?>) - Constructor for class io.confluent.security.store.kafka.KafkaStoreConfig
KafkaUtils - Class in io.confluent.security.store.kafka.clients
KafkaUtils() - Constructor for class io.confluent.security.store.kafka.clients.KafkaUtils
key() - Method in class io.confluent.security.store.kafka.clients.CachedRecord
keySerde() - Static method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
knownScopes() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
knownScopes() - Method in interface io.confluent.security.auth.store.cache.AccessRuleStore
knownScopes() - Method in class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
knownScopes() - Method in class io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore
KSQL_HEALTHCHECK_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
KSQL_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata

L

LATEST_VERSION - Static variable in class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
LDAP - Enum constant in enum class io.confluent.security.auth.provider.ldap.LdapPrincipalMapping
LDAP_FIPS_SAN_VERIFICATION_FQDN_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
LDAP_FIPS_SAN_VERIFICATION_FQDN_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
LDAP_FIPS_SAN_VERIFICATION_FQDN_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
LdapAuthenticateCallbackHandler - Class in io.confluent.security.auth.provider.ldap: LDAP authentication callback handler that can be used for simple username/password authentication.
LdapAuthenticateCallbackHandler() - Constructor for class io.confluent.security.auth.provider.ldap.LdapAuthenticateCallbackHandler
LdapConfig - Class in io.confluent.security.auth.provider.ldap
LdapConfig(Map<?, ?>) - Constructor for class io.confluent.security.auth.provider.ldap.LdapConfig
LdapConfig.SearchMode - Enum Class in io.confluent.security.auth.provider.ldap
LdapContextCreator - Class in io.confluent.security.auth.provider.ldap
LdapContextCreator(LdapConfig) - Constructor for class io.confluent.security.auth.provider.ldap.LdapContextCreator
ldapEnabled(Map<String, ?>) - Static method in class io.confluent.security.auth.provider.ldap.LdapConfig
LdapException - Exception Class in io.confluent.security.auth.provider.ldap
LdapException(String) - Constructor for exception class io.confluent.security.auth.provider.ldap.LdapException
LdapException(String, Throwable) - Constructor for exception class io.confluent.security.auth.provider.ldap.LdapException
ldapGroupManager() - Method in class io.confluent.security.auth.provider.ldap.LdapGroupProvider
LdapGroupManager - Class in io.confluent.security.auth.provider.ldap
LdapGroupManager(LdapConfig, Time) - Constructor for class io.confluent.security.auth.provider.ldap.LdapGroupManager
LdapGroupManager(LdapConfig, Time, ExternalStoreListener<UserKey, UserValue>) - Constructor for class io.confluent.security.auth.provider.ldap.LdapGroupManager
LdapGroupProvider - Class in io.confluent.security.auth.provider.ldap
LdapGroupProvider() - Constructor for class io.confluent.security.auth.provider.ldap.LdapGroupProvider
LdapGroupProvider(Time) - Constructor for class io.confluent.security.auth.provider.ldap.LdapGroupProvider
LdapPrincipalMapping - Enum Class in io.confluent.security.auth.provider.ldap
LdapStore - Class in io.confluent.security.auth.provider.ldap
LdapStore(AuthCache, KafkaAuthWriter, Time) - Constructor for class io.confluent.security.auth.provider.ldap.LdapStore
logicalClusterId() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
logicalClusterIds() - Method in class io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
logicalClusterName() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
logicalClusterType() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
LongGauge - Class in io.confluent.security.auth.utils
LongGauge(Supplier<Long>) - Constructor for class io.confluent.security.auth.utils.LongGauge

M

main(String[]) - Static method in class io.confluent.security.auth.provider.ldap.LdapConfig
main(String[]) - Static method in class io.confluent.security.store.kafka.KafkaStoreConfig
map(String) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
map(String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
masterWriterId() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
masterWriterId() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
masterWriterId() - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
masterWriterId() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
masterWriterUrl(String) - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
masterWriterUrl(String) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
masterWriterUrl(String) - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
masterWriterUrl(String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
masterWriterUrl(String) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
MATCH - Enum constant in enum class io.confluent.security.auth.metadata.PasswordVerifier.Result
matches(String, Operation, PermissionType) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAccessRule
matches(Set<KafkaPrincipal>, String, Operation, PermissionType) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAccessRule
mayDeny() - Method in class io.confluent.security.auth.dataplane.DataplaneProvider: We dont have Deny permissions in RBAC and we don't support Centralized ACLs in CCloud
mayDeny() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
mayDeny() - Method in class io.confluent.security.auth.provider.AuthnzProvider
mayDeny() - Method in class io.confluent.security.auth.provider.ConfluentProvider
MetadataNodeManager - Class in io.confluent.security.store.kafka.coordinator: Node manager for Metadata Service.
MetadataNodeManager(Collection<URL>, KafkaStoreConfig, Writer, Time) - Constructor for class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
MetadataServiceAssignment - Class in io.confluent.security.store.kafka.coordinator
MetadataServiceAssignment(short, short, Map<String, NodeMetadata>, String, NodeMetadata) - Constructor for class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
MetadataServiceAssignment(short, Map<String, NodeMetadata>, String, NodeMetadata) - Constructor for class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
MetadataServiceAssignment.AssignmentError - Enum Class in io.confluent.security.store.kafka.coordinator
MetadataServiceCoordinator - Class in io.confluent.security.store.kafka.coordinator: Coordinator for the Metadata Service used to track active nodes and elect master writer.
MetadataServiceCoordinator(LogContext, ConsumerNetworkClient, NodeMetadata, ConsumerConfig, Metrics, String, Time, MetadataServiceRebalanceListener) - Constructor for class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
MetadataServiceRebalanceListener - Interface in io.confluent.security.store.kafka.coordinator: Rebalance listener implemented by the writer manager.
MetadataStoreException - Exception Class in io.confluent.security.store
MetadataStoreException(String) - Constructor for exception class io.confluent.security.store.MetadataStoreException
metadataTopicCreateConfig(String, int) - Method in class io.confluent.security.store.kafka.KafkaStoreConfig
METRIC_GROUP - Static variable in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
METRIC_GROUP - Static variable in class io.confluent.security.auth.store.kafka.KafkaAuthStore
metricName(String, String, String, Map<String, String>) - Static method in class io.confluent.security.auth.utils.MetricsUtils
metrics() - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer.AuthnzServerInfo
metrics() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStoreMetrics
metrics() - Method in class io.confluent.security.auth.utils.AuthStoreMetrics
MetricsUtils - Class in io.confluent.security.auth.utils
MetricsUtils() - Constructor for class io.confluent.security.auth.utils.MetricsUtils
migrationTask(Authorizer) - Method in class io.confluent.security.auth.provider.ConfluentProvider
minInSyncReplicas() - Method in class io.confluent.security.store.kafka.KafkaStoreConfig
MISMATCH - Enum constant in enum class io.confluent.security.auth.metadata.PasswordVerifier.Result
MTLS_IDENTITY_POOL_COUNT - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics
MTLS_IDENTITY_PROVIDER_COUNT - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics

N

name - Variable in enum class io.confluent.security.auth.provider.ldap.LdapPrincipalMapping
newGauge(String, String, String, Map<String, String>, Supplier<T>) - Static method in class io.confluent.security.auth.utils.MetricsUtils
newMeter(MetricName, String) - Static method in class io.confluent.security.auth.utils.MetricsUtils
NodeMetadata - Class in io.confluent.security.store.kafka.coordinator
NodeMetadata(Collection<URL>) - Constructor for class io.confluent.security.store.kafka.coordinator.NodeMetadata
nodes() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
NONE - Enum constant in enum class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment.AssignmentError
NonKafkaLogicalClusterMetadata - Class in io.confluent.kafka.multitenant: Represents logical cluster metadata
NonKafkaLogicalClusterMetadata(String, String, String, String, String, String, String, String, Date, Date, String) - Constructor for class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
normalizeAcl(AclBinding) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
normalizeAcls(Collection<AclRule>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
NotMasterWriterException - Exception Class in io.confluent.security.store
NotMasterWriterException(String) - Constructor for exception class io.confluent.security.store.NotMasterWriterException
NUM_PARTITIONS - Static variable in class io.confluent.security.store.kafka.KafkaStoreConfig

O

onAssigned(MetadataServiceAssignment, int) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
onAssigned(MetadataServiceAssignment, int) - Method in interface io.confluent.security.store.kafka.coordinator.MetadataServiceRebalanceListener: Assignment completion notification generated when rebalance completes.
onConsumerRecord(ConsumerRecord<AuthKey, AuthValue>, AuthValue) - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
onConsumerRecord(ConsumerRecord<AuthKey, AuthValue>, AuthValue) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
onConsumerRecord(ConsumerRecord<AuthKey, AuthValue>, AuthValue) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
onConsumerRecord(ConsumerRecord<AuthKey, AuthValue>, AuthValue) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
onConsumerRecord(ConsumerRecord<K, V>, V) - Method in interface io.confluent.security.store.kafka.clients.ConsumerListener: Notification of new record consumed by local reader
onInit() - Method in class io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager
onProduceFailure(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener: Invoked when a record produce fails.
onProduceSuccess(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener: Invoked when a record is successfully produced
onReaderFailure() - Method in interface io.confluent.security.store.kafka.clients.StatusListener: Invoked if the consumer throws an exception while polling.
onReaderSuccess() - Method in interface io.confluent.security.store.kafka.clients.StatusListener: Invoked when a record has been processed successfully by the consumer.
onRecordConsumed(ConsumerRecord<K, V>, V, boolean) - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter: Notification of record consumed by the local reader.
onRemoteFailure(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener: Invoked when FAILED status record is consumed.
onRemoteSuccess(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener: Invoked when an INITIALIZED status record is consumed.
onRevoked(int) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
onRevoked(int) - Method in interface io.confluent.security.store.kafka.coordinator.MetadataServiceRebalanceListener: Assignment revocation notification generated when rebalance commences.
onStatusConsumed(long, int, MetadataStoreStatus, Integer) - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter: Notification of writer status read by the local reader from this partition.
onUpdate() - Method in class io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager
onUpdate(ClusterResource) - Method in class io.confluent.security.auth.provider.ConfluentProvider
onWriterFailure(int) - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter
onWriterFailure(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener: Invoked if the writer fails due to a critical error and resigns.
onWriterResigned(int) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
onWriterResigned(int) - Method in interface io.confluent.security.store.kafka.coordinator.MetadataServiceRebalanceListener: Writer resignation notification generated by the writer when an error is encountered, cache refresh times out or a generation marker with newer generation is is received.
onWriterSuccess(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener: Invoked when the writer is successfully initialized.
operationGroup() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAccessRule
organizationId() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
overrideDefaultSslFactoryConfig(Map<String, ?>, String) - Static method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory

P

partitionWriter(int) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
PasswordVerifier - Interface in io.confluent.security.auth.metadata: Password verifier for comparing passwords during authentication.
PasswordVerifier.Result - Enum Class in io.confluent.security.auth.metadata
PERSISTENT_REFRESH - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
physicalClusterId() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
PREFIX - Static variable in class io.confluent.security.store.kafka.KafkaStoreConfig
PRINCIPAL_MAPPING_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
PRINCIPAL_MAPPING_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
PRINCIPAL_MAPPING_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
processConsumerRecord(ConsumerRecord<K, V>) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthReader
producerConfigs(String) - Method in class io.confluent.security.store.kafka.KafkaStoreConfig
PROTOCOL - Static variable in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
PROVIDER_NAME - Static variable in class io.confluent.security.auth.dataplane.DataplaneProvider
PROVIDER_NAME - Static variable in class io.confluent.security.auth.ipFiltering.DryRunIpFilteringProvider
PROVIDER_NAME - Static variable in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
PROVIDER_NAME - Static variable in class io.confluent.security.auth.provider.AuthnzProvider
providerConfigured(Map<String, ?>) - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
providerConfigured(Map<String, ?>) - Method in class io.confluent.security.auth.provider.ConfluentProvider: Brokers running ConfluentProvider should be either: - in the metadata cluster, running MDS.
providerConfigured(Map<String, ?>) - Method in class io.confluent.security.auth.provider.ldap.LdapGroupProvider
providerName() - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
providerName() - Method in class io.confluent.security.auth.ipFiltering.DryRunIpFilteringProvider
providerName() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
providerName() - Method in class io.confluent.security.auth.provider.AuthnzProvider
providerName() - Method in class io.confluent.security.auth.provider.ConfluentProvider
providerName() - Method in class io.confluent.security.auth.provider.ldap.LdapGroupProvider
put(AuthKey, AuthValue) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
put(AuthKey, AuthValue) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache

R

RBAC_ACCESS_RULES_COUNT - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics
RBAC_ROLE_BINDINGS_COUNT - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics
rbacRoleBindings(Scope) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
rbacRoleBindings(RoleBindingFilter) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
rbacRoleBindings(Set<Scope>) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
rbacRoleBindings(KafkaPrincipal) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
rbacRoleBindings(KafkaPrincipal, Set<Scope>) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
rbacRoles() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
ready() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
ready() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
ready() - Method in interface io.confluent.security.store.kafka.clients.Writer: Returns true if this is the master writer and is ready to process requests
RECORD_IP_FILTERING_LATENCY_GAUGE - Static variable in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStoreMetrics
RECORD_IP_FILTERING_LATENCY_METRIC - Static variable in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStoreMetrics
RECORD_LATENCY_GAUGE - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics
RECORD_LATENCY_METRIC - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics
recordLatencyMetric(LatencyRecordKey, long) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStoreMetrics
recordLatencyMetric(LatencyRecordKey, long) - Method in class io.confluent.security.auth.utils.AuthStoreMetrics
recordsProcessedSensors - Variable in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStoreMetrics
recordsProcessedSensors - Variable in class io.confluent.security.auth.utils.AuthStoreMetrics
REFRESH_INTERVAL_MS_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
REFRESH_INTERVAL_MS_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
REFRESH_INTERVAL_MS_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
REFRESH_TIMEOUT_PROP - Static variable in class io.confluent.security.store.kafka.KafkaStoreConfig
REFRESH_TOKEN_INFOS_COUNT - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics
refreshTimeout - Variable in class io.confluent.security.store.kafka.KafkaStoreConfig
refreshTokenInfo(String) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
registerLatencyGauge(String, Supplier<Long>) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStoreMetrics
registerLatencyGauge(String, Supplier<Long>) - Method in class io.confluent.security.auth.utils.AuthStoreMetrics
remove(AuthKey) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
remove(AuthKey) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
remove(Scope, ResourcePattern) - Method in interface io.confluent.security.auth.store.cache.AccessRuleStore
remove(Scope, ResourcePattern) - Method in class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
remove(Scope, ResourcePattern) - Method in class io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore
removeCertificates(String, String) - Method in class io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager
removeDeletedAccessRules(Scope, KafkaPrincipal, Map<ResourcePattern, Set<AccessRule>>) - Method in interface io.confluent.security.auth.store.cache.AccessRuleStore
removeDeletedAccessRules(Scope, KafkaPrincipal, Map<ResourcePattern, Set<AccessRule>>) - Method in class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
removeDeletedAccessRules(Scope, KafkaPrincipal, Map<ResourcePattern, Set<AccessRule>>) - Method in class io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore
removeIdentityPool(Optional<Principal>, String, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
removeIdentityPool(Optional<Principal>, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
removeIdentityProvider(Optional<Principal>, String, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
removeIdentityProvider(Optional<Principal>, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
removeJwks(Optional<Principal>, String, String, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
removeJwks(Optional<Principal>, String, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
removeMetrics(Set<MetricName>) - Static method in class io.confluent.security.auth.utils.MetricsUtils
removeRefreshTokenInfo(Optional<Principal>, String, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
removeRefreshTokenInfo(Optional<Principal>, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
removeResourceRoleBinding(Optional<KafkaPrincipal>, KafkaPrincipal, String, Scope, Collection<ResourcePatternFilter>, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
removeResourceRoleBinding(Optional<KafkaPrincipal>, KafkaPrincipal, String, Scope, Collection<ResourcePatternFilter>, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
removeRoleBinding(Optional<KafkaPrincipal>, KafkaPrincipal, String, Scope, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
removeRoleBinding(Optional<KafkaPrincipal>, KafkaPrincipal, String, Scope, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
replaceIdentityPool(Optional<Principal>, String, int, String, String, String, String, String, String, String, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
replaceIdentityPool(Optional<Principal>, String, int, String, String, String, String, String, String, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
replaceIdentityProvider(Optional<Principal>, String, String, String, String, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
replaceIdentityProvider(Optional<Principal>, String, String, String, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
replaceJwks(Optional<Principal>, String, String, JsonWebKeySet, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
replaceJwks(Optional<Principal>, String, String, JsonWebKeySet, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
replaceRefreshTokenInfo(Optional<Principal>, String, String, long, String, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
replaceRefreshTokenInfo(Optional<Principal>, String, String, long, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
replaceResourceRoleBinding(Optional<KafkaPrincipal>, KafkaPrincipal, String, Scope, Collection<ResourcePattern>, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
replaceResourceRoleBinding(Optional<KafkaPrincipal>, KafkaPrincipal, String, Scope, Collection<ResourcePattern>, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
REPLICATION_FACTOR_PROP - Static variable in class io.confluent.security.store.kafka.KafkaStoreConfig
resetFailure() - Method in interface io.confluent.security.auth.store.external.ExternalStoreListener: Indicates that external store is functioning after an earlier failure.
RETRY_BACKOFF_MAX_MS_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
RETRY_BACKOFF_MAX_MS_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
RETRY_BACKOFF_MAX_MS_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
RETRY_BACKOFF_MS_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
RETRY_BACKOFF_MS_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
RETRY_BACKOFF_MS_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
RETRY_TIMEOUT_MS_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
RETRY_TIMEOUT_MS_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
RETRY_TIMEOUT_MS_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
RETRY_TIMEOUT_PROP - Static variable in class io.confluent.security.store.kafka.KafkaStoreConfig
RetryBackoff - Class in io.confluent.security.auth.utils
RetryBackoff(int, int) - Constructor for class io.confluent.security.auth.utils.RetryBackoff
retryPredicate(Exception) - Static method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
retryTimeout - Variable in class io.confluent.security.store.kafka.KafkaStoreConfig
rootScope() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
ruleCount() - Method in interface io.confluent.security.auth.store.cache.AccessRuleStore
ruleCount() - Method in class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
ruleCount() - Method in class io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore
run() - Method in class io.confluent.security.store.kafka.clients.KafkaReader

S

SCHEMA_REGISTRY_HEALTHCHECK_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
SCHEMA_REGISTRY_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
scope() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAccessRule
ScopeAccessRuleStore - Class in io.confluent.security.auth.store.cache: AccessRuleStore to be used only for CP RBAC.
ScopeAccessRuleStore() - Constructor for class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
ScopeAccessRuleStore(Map<Scope, NavigableMap<ResourcePattern, Set<AccessRule>>>) - Constructor for class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
ScopePrincipalAccessRuleStore - Class in io.confluent.security.auth.store.cache: AccessRuleStore to be used only for Cloud RBAC.
ScopePrincipalAccessRuleStore() - Constructor for class io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore
ScopePrincipalAccessRuleStore(Map<Scope, Map<KafkaPrincipal, NavigableMap<ResourcePattern, Set<AccessRule>>>>) - Constructor for class io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore
SEARCH_MODE_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
SEARCH_MODE_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
SEARCH_MODE_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
SEARCH_PAGE_SIZE_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
SEARCH_PAGE_SIZE_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
SEARCH_PAGE_SIZE_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
serde(Class<T>, boolean) - Static method in class io.confluent.security.store.kafka.clients.JsonSerde
serde(Class<T>, boolean, Function<DeserializationErrorHandlingJsonSerde.DeserializationError, T>) - Static method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde
serialize() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
serialize() - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
serialize(String, T) - Method in class io.confluent.security.store.kafka.clients.JsonSerde
serializer() - Method in class io.confluent.security.store.kafka.clients.JsonSerde
setAdminSupplierAndCreateClient(Supplier<AdminClient>) - Method in class io.confluent.security.auth.mtls.DefaultMTlsTruststoreManager: When using this class in a Kafka broker, the AdminClient instance is required to update the broker's dynamic SSL truststore configuration.
setCrlVerificationDisabled(boolean) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
setKafkaMetrics(Metrics) - Method in class io.confluent.security.auth.provider.AuthnzProvider
setKafkaMetrics(Metrics) - Method in class io.confluent.security.auth.provider.ConfluentProvider
setMTlsConnectionManager(MTlsConnectionManager) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
setMTlsTruststoreManager(MTlsTruststoreManager) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
start() - Method in class io.confluent.security.auth.provider.ldap.LdapGroupManager: Starts the LDAP group manager and schedules either periodic or persistent search.
start() - Method in interface io.confluent.security.auth.store.external.ExternalStoreListener
start() - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
start(int) - Method in class io.confluent.security.auth.provider.ldap.LdapStore
start(int) - Method in interface io.confluent.security.auth.store.external.ExternalStore: Starts consuming metadata from the external store.
start(int, K, V, ScheduledExecutorService) - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter: Starts this partition writer with the provided generation id.
start(Duration) - Method in class io.confluent.security.store.kafka.clients.KafkaReader
start(Map<String, Object>, Collection<Endpoint>) - Method in class io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
start(Metrics) - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer
start(AuthorizerServerInfo) - Method in class io.confluent.security.auth.provider.AuthnzProvider
start(AuthorizerServerInfo) - Method in class io.confluent.security.auth.provider.ConfluentProvider
start(ConfluentAuthorizerServerInfo) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
start(ConfluentAuthorizerServerInfo) - Method in class io.confluent.security.auth.provider.AuthnzProvider
start(ConfluentAuthorizerServerInfo) - Method in class io.confluent.security.auth.provider.ConfluentProvider: Starts the RBAC provider.
start(ConfluentAuthorizerServerInfo, Runnable) - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer
startClients(Function<String, Admin>) - Method in class io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
startReader() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
startReader() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
startReader() - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
startReader() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
startService(Collection<URL>) - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
startService(Collection<URL>) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
startService(Collection<URL>) - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
startService(Collection<URL>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
startWriter(int) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
startWriter(int) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
startWriter(int) - Method in interface io.confluent.security.store.kafka.clients.Writer: Starts master writer with the specified generation id.
status(int) - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
status(int) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
StatusListener - Interface in io.confluent.security.store.kafka.clients: Interface to listener for failure status of KafkaStore readers and writers
stop() - Method in interface io.confluent.security.auth.store.external.ExternalStoreListener
stop() - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter: Stops this writer in preparation for rebalance.
stop(Integer) - Method in class io.confluent.security.auth.provider.ldap.LdapStore
stop(Integer) - Method in interface io.confluent.security.auth.store.external.ExternalStore: Stops consuming metadata from the external store if the provided generation id is null or equal to the current generation id of this store.
stopWriter(Integer) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
stopWriter(Integer) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
stopWriter(Integer) - Method in interface io.confluent.security.store.kafka.clients.Writer: Stops this writer because a new master writer was elected.

T

TOPIC_CREATE_TIMEOUT_PROP - Static variable in class io.confluent.security.store.kafka.KafkaStoreConfig
TOPIC_PREFIX - Static variable in class io.confluent.security.store.kafka.KafkaStoreConfig
topicCreateTimeout - Variable in class io.confluent.security.store.kafka.KafkaStoreConfig
toString() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
toString() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.DeserializerErrorForKey
toString() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.DeserializerErrorForValue
toString() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAccessRule
toString() - Method in class io.confluent.security.auth.provider.ldap.LdapAuthenticateCallbackHandler
toString() - Method in class io.confluent.security.auth.provider.ldap.LdapConfig
toString() - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde.DeserializationError
toString() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
toString() - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
toString() - Method in class io.confluent.security.store.kafka.KafkaStoreConfig
totalAclAccessRules() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
totalIdentityPools() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
totalIpFilteringAccessRules() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
totalIpFilterings() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
totalJwtIssuers() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
totalRbacAccessRules() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
totalRefreshTokenInfos() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
totalRoleBindings() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
trustCache() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
trustCache() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
trustCache() - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
trustCache() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore

U

UNKNOWN - Enum constant in enum class io.confluent.security.auth.metadata.PasswordVerifier.Result
update(Scope, ResourcePattern, Set<AccessRule>) - Method in interface io.confluent.security.auth.store.cache.AccessRuleStore
update(Scope, ResourcePattern, Set<AccessRule>) - Method in class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
update(Scope, ResourcePattern, Set<AccessRule>) - Method in class io.confluent.security.auth.store.cache.ScopePrincipalAccessRuleStore
update(K, Function<V, V>) - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter: Reads the record for key, applies a transformation and stores it back on the topic.
update(K, V) - Method in interface io.confluent.security.auth.store.external.ExternalStoreListener: Invoked when a refresh of the external store finds a new entry or an updated entry.
updateAuthCacheExternally(byte[], byte[]) - Method in class io.confluent.security.auth.provider.ConfluentProvider
updateAuthCacheExternally(byte[], byte[]) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
updateStoreAuthCacheExternally(byte[], byte[]) - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
uris() - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
url(String) - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
urls() - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
USER_DN_NAME_PATTERN_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_DN_NAME_PATTERN_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_DN_NAME_PATTERN_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_MEMBEROF_ATTRIBUTE_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_MEMBEROF_ATTRIBUTE_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_MEMBEROF_ATTRIBUTE_PATTERN_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_MEMBEROF_ATTRIBUTE_PATTERN_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_MEMBEROF_ATTRIBUTE_PATTERN_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_MEMBEROF_ATTRIBUTE_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_NAME_ATTRIBUTE_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_NAME_ATTRIBUTE_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_NAME_ATTRIBUTE_PATTERN_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_NAME_ATTRIBUTE_PATTERN_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_NAME_ATTRIBUTE_PATTERN_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_NAME_ATTRIBUTE_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_OBJECT_CLASS_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_OBJECT_CLASS_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_OBJECT_CLASS_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_PASSWORD_ATTRIBUTE_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_PASSWORD_ATTRIBUTE_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_SEARCH_BASE_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_SEARCH_BASE_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_SEARCH_BASE_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_SEARCH_FILTER_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_SEARCH_FILTER_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_SEARCH_FILTER_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_SEARCH_SCOPE_DEFAULT - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_SEARCH_SCOPE_DOC - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
USER_SEARCH_SCOPE_PROP - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
userMetadata(KafkaPrincipal) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
users() - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
USERS - Enum constant in enum class io.confluent.security.auth.provider.ldap.LdapConfig.SearchMode
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringProvider
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.security.auth.provider.AuthnzProvider
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.security.auth.provider.ConfluentProvider: Returns true if this broker or controller is running in Metadata service cluster as indicated by MetadataServerConfig.METADATA_SERVER_CONTROLLER_KRAFT_ENABLED_PROP
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.security.auth.provider.ldap.LdapGroupProvider

V

validateCidr(String) - Static method in class io.confluent.security.auth.ipFiltering.IpFilteringUtils
validateRoleBindingUpdate(String, Scope, Collection<?>, boolean, Scope, RbacRoles) - Static method in class io.confluent.security.auth.utils.AuthWriterUtils
validateRoleResources(Collection<ResourcePattern>) - Static method in class io.confluent.security.auth.utils.AuthWriterUtils
validateScope(Scope, Scope) - Static method in class io.confluent.security.auth.utils.AuthWriterUtils
value() - Method in class io.confluent.security.store.kafka.clients.CachedRecord
value(MetricConfig, long) - Method in class io.confluent.security.auth.utils.LongGauge
valueOf(String) - Static method in enum class io.confluent.security.auth.metadata.PasswordVerifier.Result: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.security.auth.provider.ldap.LdapConfig.SearchMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.security.auth.provider.ldap.LdapPrincipalMapping: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment.AssignmentError: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.confluent.security.auth.metadata.PasswordVerifier.Result: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.security.auth.provider.ldap.LdapConfig.SearchMode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.security.auth.provider.ldap.LdapPrincipalMapping: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment.AssignmentError: Returns an array containing the constants of this enum class, in the order they are declared.
valueSerde() - Static method in class io.confluent.security.auth.dataplane.DataplaneAuthStore
valueSerde() - Static method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
verify(char[], char[]) - Method in interface io.confluent.security.auth.metadata.PasswordVerifier
version() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment

W

waitForTopic(String, int, Time, Duration, Function<String, Set<Integer>>, Consumer<String>) - Static method in class io.confluent.security.store.kafka.clients.KafkaUtils: Waits for full partition metadata for topic with `numPartitions` partitions to be available.
withBackOff(Supplier<T>, Predicate<Exception>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore.BackOffDecorator
write(K, V, Integer, boolean, boolean) - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter: Writes a record to the partition, queuing the request if necessary until this writer is ready and the number of pending writes is within the limit.
writeExternalEntry(AuthKey, AuthValue, Integer) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter: Writes an external metadata entry into the partition corresponding to the provided key.
writeExternalStatus(MetadataStoreStatus, String, int) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
writer() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
writer() - Method in class io.confluent.security.auth.ipFiltering.IpFilteringAuthStore
writer() - Method in class io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore
writer() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
Writer - Interface in io.confluent.security.store.kafka.clients
writerMemberId() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
writerNodeMetadata() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
writeStatus(int, K, V, MetadataStoreStatus) - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter

X

x509CertificatesFromPem(String) - Static method in class io.confluent.security.auth.mtls.CaCertificatesUtils: Parse PEM encoded certificates to X509Certificate objects.
x509CertificatesFromPemFile(Path) - Static method in class io.confluent.security.auth.mtls.CaCertificatesUtils: Parse PEM encoded certificates from a file to X509Certificate objects
x509CrlFromPem(String) - Static method in class io.confluent.security.auth.mtls.CaCertificatesUtils: Parse PEM encoded CRL to X509CRL object
x509CrlToPem(X509CRL) - Static method in class io.confluent.security.auth.mtls.CaCertificatesUtils: Convert X509CRL to PEM format

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