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

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.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
 
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) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
 
addIdentityPool(Optional<Principal>, String, int, String, String, 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
 
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.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
 
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
 
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
 
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.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
 
AuthStoreMetrics.LongGauge - Class in io.confluent.security.auth.utils
 
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() - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer.AuthnzServerInfo
 
brokerId - Variable in class io.confluent.security.store.kafka.KafkaStoreConfig
 

C

CachedRecord<K,V> - Class in io.confluent.security.store.kafka.clients
 
close(Duration) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthReader
 
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.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.KafkaAuthStore.BackOffDecorator
 
close() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
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() - Method in class io.confluent.security.store.kafka.clients.JsonSerde
 
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
 
CONFIG_PREFIX - Static variable in class io.confluent.security.auth.provider.ldap.LdapConfig
 
ConfigurableSslSocketFactory - Class in io.confluent.security.auth.utils
 
ConfigurableSslSocketFactory() - Constructor for class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
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.provider.AuthnzProvider
 
configure(Map<String, ?>) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.security.auth.provider.ldap.LdapAuthenticateCallbackHandler
 
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.KafkaAuthStore
 
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, ?>) - Method in class io.confluent.security.store.kafka.clients.JsonSerde
 
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, AclBinding) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
 
createAcls(Optional<KafkaPrincipal>, Scope, List<AclBinding>) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
 
createAcls(AuthorizableRequestContext, List<AclBinding>) - Method in class io.confluent.security.auth.provider.AuthnzProvider
 
createAcls(AuthorizableRequestContext, List<AclBinding>, Optional<String>) - 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.ConfluentProvider
 
createAcls(Optional<KafkaPrincipal>, Scope, AclBinding) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
 
createAcls(Optional<KafkaPrincipal>, Scope, List<AclBinding>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
 
createLdapContext() - Method in class io.confluent.security.auth.provider.ldap.LdapContextCreator
 
createRbacAuthorizer() - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
createSocket(Socket, String, int, boolean) - Method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
createSocket() - Method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
createSocket(String, int) - Method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
createSocket(String, int, InetAddress, int) - Method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
createSocket(InetAddress, int) - Method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
createSocket(InetAddress, int, InetAddress, int) - Method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
createSocket(Socket, InputStream, boolean) - Method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
createSslFactory(Map<String, ?>) - Static method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
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, Meter) - 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) - 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
 
DefaultAuthCache - Class in io.confluent.security.auth.store.cache
 
DefaultAuthCache(RbacRoles, Scope, ScopeAccessRuleStore, ScopeAccessRuleStore) - Constructor for class io.confluent.security.auth.store.cache.DefaultAuthCache
 
DefaultAuthCache(RbacRoles, Scope) - Constructor for class io.confluent.security.auth.store.cache.DefaultAuthCache
 
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, 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.dataplane.DataplaneAuthWriter
 
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>) - Method in class io.confluent.security.auth.provider.AuthnzProvider
 
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>, Optional<String>, AclState) - 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.ConfluentProvider
 
deleteAcls(Optional<KafkaPrincipal>, Scope, AclBindingFilter, Predicate<ResourcePattern>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
 
deleteAcls(Optional<KafkaPrincipal>, Scope, List<AclBindingFilter>, Predicate<ResourcePattern>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
 
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, Headers, byte[]) - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde
 
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(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
 

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 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.
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.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.
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(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.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
 
fromProtobuf(LogicalCluster) - Static method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
 

G

generationIdDuringRead() - Method in class io.confluent.security.store.kafka.clients.CachedRecord
 
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
 
getData() - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde.DeserializationError
 
getDefault() - Static method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
getDefaultCipherSuites() - 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
 
getSupportedCipherSuites() - Method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
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.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(KafkaPrincipal) - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
 
groups(KafkaPrincipal) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
groups(String) - Method in class io.confluent.security.auth.provider.ldap.LdapGroupManager
 
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.

H

handle(Callback[]) - Method in class io.confluent.security.auth.provider.ldap.LdapAuthenticateCallbackHandler
 
handleSocketServerInitialized() - Method in class io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
 
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
 
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.metadata - package io.confluent.security.auth.metadata
 
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
 
isActive() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
 
isForKey() - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde.DeserializationError
 
isHealthcheckLogicalCluster() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
 
isMasterWriter() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
 
isMasterWriter() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
isMasterWriter() - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
 
isSuperUser(KafkaPrincipal, Scope) - Method in class io.confluent.security.auth.provider.AuthnzProvider
 
isSuperUser(KafkaPrincipal, Scope) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
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(AuthorizerServerInfo, Map<?, ?>) - Constructor for class io.confluent.security.store.kafka.KafkaStoreConfig
 
KafkaStoreConfig(int, 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
 
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 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 in io.confluent.security.auth.provider.ldap
 
LdapException(String) - Constructor for exception io.confluent.security.auth.provider.ldap.LdapException
 
LdapException(String, Throwable) - Constructor for exception io.confluent.security.auth.provider.ldap.LdapException
 
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
 
ldapGroupManager() - Method in class io.confluent.security.auth.provider.ldap.LdapGroupProvider
 
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 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
 

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.store.cache.AbstractAuthCache
 
masterWriterId() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
 
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.store.kafka.KafkaAuthStore
 
masterWriterUrl(String) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
 
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.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, Map<String, NodeMetadata>, String, NodeMetadata) - Constructor for class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
 
MetadataServiceAssignment(short, short, Map<String, NodeMetadata>, String, NodeMetadata) - Constructor for class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
 
MetadataServiceAssignment.AssignmentError - Enum 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 in io.confluent.security.store
 
MetadataStoreException(String) - Constructor for exception 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.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.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
 

N

name - Variable in enum 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
 
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 in io.confluent.security.store
 
NotMasterWriterException(String) - Constructor for exception 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.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
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(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.
organizationId() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
 

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 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
 
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.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.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.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(Set<Scope>) - Method in class io.confluent.security.auth.store.cache.AbstractAuthCache
 
rbacRoleBindings(RoleBindingFilter) - 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_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.utils.AuthStoreMetrics
 
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.utils.AuthStoreMetrics
 
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
 
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
 
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) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
 
replaceIdentityPool(Optional<Principal>, String, int, String, String, 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
 
ScopeAccessRuleStore - Class in io.confluent.security.auth.store.cache
AccessRuleStore to be used only for CP RBAC.
ScopeAccessRuleStore(Map<Scope, NavigableMap<ResourcePattern, Set<AccessRule>>>) - Constructor for class io.confluent.security.auth.store.cache.ScopeAccessRuleStore
 
ScopeAccessRuleStore() - 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, Function<DeserializationErrorHandlingJsonSerde.DeserializationError, T>) - Static method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde
 
serde(Class<T>, boolean) - Static method in class io.confluent.security.store.kafka.clients.JsonSerde
 
serialize(String, T) - Method in class io.confluent.security.store.kafka.clients.JsonSerde
 
serialize() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
 
serialize() - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
 
serializer() - Method in class io.confluent.security.store.kafka.clients.JsonSerde
 
setKafkaMetrics(Metrics) - Method in class io.confluent.security.auth.provider.AuthnzProvider
 
setKafkaMetrics(Metrics) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
start(Metrics) - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer
 
start(ConfluentAuthorizerServerInfo, Runnable) - Method in class io.confluent.security.auth.dataplane.AuthnzServerAuthorizer
 
start(Map<String, Object>, Collection<Endpoint>) - Method in class io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
 
start(ConfluentAuthorizerServerInfo) - Method in class io.confluent.security.auth.provider.AuthnzProvider
 
start(AuthorizerServerInfo) - 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(AuthorizerServerInfo) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
start() - Method in class io.confluent.security.auth.provider.ldap.LdapGroupManager
Starts the LDAP group manager and schedules either periodic or persistent search.
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() - Method in interface io.confluent.security.auth.store.external.ExternalStoreListener
 
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() - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
 
startReader() - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
 
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.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.store.cache.AbstractAuthCache
 
StatusListener - Interface in io.confluent.security.store.kafka.clients
Interface to listener for failure status of KafkaStore readers and writers
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.
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.
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.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
 
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.store.kafka.KafkaAuthStore
 

U

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, 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.
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.
updateClientConfigs(Map<String, Object>) - Method in class io.confluent.security.auth.dataplane.AuthnzTopicBasedPhysicalClusterMetadata
 
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
 
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
 
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

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(MetricConfig, long) - Method in class io.confluent.security.auth.utils.AuthStoreMetrics.LongGauge
 
value() - Method in class io.confluent.security.store.kafka.clients.CachedRecord
 
valueOf(String) - Static method in enum io.confluent.security.auth.metadata.PasswordVerifier.Result
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.security.auth.provider.ldap.LdapConfig.SearchMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.security.auth.provider.ldap.LdapPrincipalMapping
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment.AssignmentError
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.confluent.security.auth.metadata.PasswordVerifier.Result
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.security.auth.provider.ldap.LdapConfig.SearchMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.security.auth.provider.ldap.LdapPrincipalMapping
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment.AssignmentError
Returns an array containing the constants of this enum type, 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, int) - 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.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
 
A B C D E F G H I J K L M N O P R S T U V W 
Skip navigation links