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

ACL_ACCESS_RULES_COUNT - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics
 
AclBindingKey - Class in io.confluent.security.auth.store.data
 
AclBindingKey(ResourcePattern, Scope) - Constructor for class io.confluent.security.auth.store.data.AclBindingKey
 
aclBindings(Scope, AclBindingFilter, Predicate<ResourcePattern>) - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns ACL bindings which match the provided filter.
aclBindings(Scope, AclBindingFilter, Predicate<ResourcePattern>) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
AclBindingValue - Class in io.confluent.security.auth.store.data
 
AclBindingValue(Collection<AclRule>) - Constructor for class io.confluent.security.auth.store.data.AclBindingValue
 
aclRules(Scope) - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns the ACL rules for all resources of given scope
aclRules(Scope) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
aclRules() - Method in class io.confluent.security.auth.store.data.AclBindingValue
 
acls(AclBindingFilter) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
activeNodeUrls(String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore
 
activeNodeUrls(String) - Method in interface io.confluent.security.auth.metadata.AuthStore
Returns the collection of URLS of currently active nodes.
activeNodeUrls(String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
activeNodeUrls(String) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
 
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 interface io.confluent.security.auth.metadata.AuthWriter
Adds a new cluster-level role binding without any resources.
addClusterRoleBinding(KafkaPrincipal, String, Scope) - Method in interface io.confluent.security.auth.metadata.AuthWriter
 
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) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
 
addIdentityPool(Optional<Principal>, String, int, String, String, String, String, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
 
addInstance(String, AuthStore, Logger) - Static method in interface io.confluent.security.auth.metadata.AuthStore
 
addJwtIssuer(Optional<Principal>, String, JsonWebKeySet, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
 
addJwtIssuer(Optional<Principal>, 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 interface io.confluent.security.auth.metadata.AuthCache
Adds RBAC or ACL rules for the specified principals that match the provided parameters to `matchingRules`.
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.DefaultAuthCache
 
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 interface io.confluent.security.auth.metadata.AuthWriter
Adds resources to a role binding.
addResourceRoleBinding(KafkaPrincipal, String, Scope, Collection<ResourcePattern>) - Method in interface io.confluent.security.auth.metadata.AuthWriter
 
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
 
audience() - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache
audience(Set<String>) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder
 
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.DataplaneAuthStore
 
AuthCache - Interface in io.confluent.security.auth.metadata
Cache containing authorization and authentication metadata.
authCache() - Method in interface io.confluent.security.auth.metadata.AuthStore
Returns a cache that stores all data read from the auth topic.
authCache() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
AuthCache.Result - Class in io.confluent.security.auth.metadata
The result of a health check call.
AuthEntryType - Enum in io.confluent.security.auth.store.data
 
AuthKey - Class in io.confluent.security.auth.store.data
 
AuthKey() - Constructor for class io.confluent.security.auth.store.data.AuthKey
 
authorize(AuthorizableRequestContext, List<Action>) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
AuthStore - Interface in io.confluent.security.auth.metadata
Store containing authorization and authentication metadata.
authStore() - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
AuthStoreMetrics - Class in io.confluent.security.auth.utils
 
AuthStoreMetrics(Metrics, DefaultAuthCache) - 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.ConfluentProvider
 
AuthValue - Class in io.confluent.security.auth.store.data
 
AuthValue() - Constructor for class io.confluent.security.auth.store.data.AuthValue
 
AuthWriter - Interface in io.confluent.security.auth.metadata
Writer interface used by Metadata Server to update role bindings.
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

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
 
build() - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder
Construct new JwtIssuerAuthCache instance.
builder() - Static method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache
 

C

cache - Variable in class io.confluent.security.store.kafka.clients.KafkaReader
 
CachedRecord<K,V> - Class in io.confluent.security.store.kafka.clients
 
checkSniHostNameMatched(OAuthBearerExtensionsValidatorCallback, String, String, SniValidationMode) - Method in class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler
 
clazz - Variable in class io.confluent.security.store.kafka.clients.JsonSerde
 
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.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.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler
 
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
 
close(Timer) - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
 
compareTo(NodeMetadata) - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
 
CONFIG_PREFIX - Static variable in class io.confluent.security.auth.dataplane.JwtAuthenticatorConfig
 
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.DataplaneAuthStore
 
configure(Map<String, ?>) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache
 
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, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler
 
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
 
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
 
consumerListener - Variable in class io.confluent.security.store.kafka.clients.KafkaReader
 
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(Optional<KafkaPrincipal>, Scope, AclBinding) - Method in interface io.confluent.security.auth.metadata.AuthWriter
Creates ACL rules for a given AclBinding.
createAcls(Scope, AclBinding) - Method in interface io.confluent.security.auth.metadata.AuthWriter
 
createAcls(Optional<KafkaPrincipal>, Scope, List<AclBinding>) - Method in interface io.confluent.security.auth.metadata.AuthWriter
Creates ACLs for the specified scope using the minimal number of batched updates.
createAcls(Scope, List<AclBinding>) - Method in interface io.confluent.security.auth.metadata.AuthWriter
 
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
 
createAdminClient(Map<String, Object>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
createAuthStore(Scope, ConfluentAuthorizerServerInfo, Map<String, ?>) - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
 
createAuthStore(Scope, ConfluentAuthorizerServerInfo, Map<String, ?>) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
createConsumer(Map<String, Object>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
createKafkaClient(ConsumerConfig, Metadata, Time, LogContext) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
 
createLdapContext() - Method in class io.confluent.security.auth.provider.ldap.LdapContextCreator
 
createLdapGroupManager(ExternalStoreListener<UserKey, UserValue>) - Method in class io.confluent.security.auth.provider.ldap.LdapStore
 
createLdapStore(Map<String, ?>, DefaultAuthCache) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
 
createMdsAdminClient(AuthorizerServerInfo, Map<String, ?>) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
createNodeManager(Collection<URL>, KafkaStoreConfig, KafkaAuthWriter, Time) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
createProducer(Map<String, Object>) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
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
 
createWriter(int, KafkaStoreConfig, DefaultAuthCache, StatusListener, Time) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 

D

DataplaneAuthReader<K,V> - Class in io.confluent.security.auth.dataplane
 
DataplaneAuthReader(String, int, 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
 
DataplaneAuthStore.DeserializerErrorForKey - Class in io.confluent.security.auth.dataplane
 
DataplaneAuthStore.DeserializerErrorForValue - Class in io.confluent.security.auth.dataplane
 
DataplaneAuthWriter - Class in io.confluent.security.auth.dataplane
 
DataplaneAuthWriter() - Constructor for class io.confluent.security.auth.dataplane.DataplaneAuthWriter
 
DataplaneProvider - Class in io.confluent.security.auth.dataplane
 
DataplaneProvider() - Constructor for class io.confluent.security.auth.dataplane.DataplaneProvider
 
DefaultAuthCache - Class in io.confluent.security.auth.store.cache
Cache containing authorization and authentication metadata.
DefaultAuthCache(RbacRoles, Scope) - Constructor for class io.confluent.security.auth.store.cache.DefaultAuthCache
 
DefaultAuthCache(RbacRoles, Scope, boolean) - 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(Optional<KafkaPrincipal>, Scope, AclBindingFilter, Predicate<ResourcePattern>) - Method in interface io.confluent.security.auth.metadata.AuthWriter
Deletes all ACL rules that match the provided filters.
deleteAcls(Scope, AclBindingFilter, Predicate<ResourcePattern>) - Method in interface io.confluent.security.auth.metadata.AuthWriter
 
deleteAcls(Optional<KafkaPrincipal>, Scope, List<AclBindingFilter>, Predicate<ResourcePattern>) - Method in interface io.confluent.security.auth.metadata.AuthWriter
Deletes ACLs that match any of the provided filters using batched update.
deleteAcls(Scope, List<AclBindingFilter>, Predicate<ResourcePattern>) - Method in interface io.confluent.security.auth.metadata.AuthWriter
 
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>, Optional<String>) - 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
 
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.DataplaneAuthStore.DeserializerErrorForKey
 
DeserializerErrorForValue(DeserializationErrorHandlingJsonSerde.DeserializationError) - Constructor for class io.confluent.security.auth.dataplane.DataplaneAuthStore.DeserializerErrorForValue
 

E

elapsedSeconds(Time, long) - Static method in class io.confluent.security.auth.utils.MetricsUtils
 
EnhancedOAuthBearerValidatorCallbackHandler - Class in io.confluent.security.auth.provider.oauth
A CallbackHandler that recognizes OAuthBearerValidatorCallback and OAuthBearerExtensionsValidatorCallback for validating a secured OAuth 2 bearer token issued by Confluent/external OIDC provider, SASL extensions specifying the logical cluster this token is meant for and an identity pool ID to assume if token is from external OIDC provider.
EnhancedOAuthBearerValidatorCallbackHandler() - Constructor for class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler
 
entryType() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore.DeserializerErrorForKey
 
entryType() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore.DeserializerErrorForValue
 
entryType() - Method in class io.confluent.security.auth.store.data.AclBindingKey
 
entryType() - Method in class io.confluent.security.auth.store.data.AclBindingValue
 
entryType() - Method in class io.confluent.security.auth.store.data.AuthKey
 
entryType() - Method in class io.confluent.security.auth.store.data.AuthValue
 
entryType() - Method in class io.confluent.security.auth.store.data.IdentityPoolKey
 
entryType() - Method in class io.confluent.security.auth.store.data.IdentityPoolValue
 
entryType() - Method in class io.confluent.security.auth.store.data.JwtIssuerKey
 
entryType() - Method in class io.confluent.security.auth.store.data.JwtIssuerValue
 
entryType() - Method in class io.confluent.security.auth.store.data.RoleBindingKey
 
entryType() - Method in class io.confluent.security.auth.store.data.RoleBindingValue
 
entryType() - Method in class io.confluent.security.auth.store.data.StatusKey
 
entryType() - Method in class io.confluent.security.auth.store.data.StatusValue
 
entryType() - Method in class io.confluent.security.auth.store.data.UserKey
 
entryType() - Method in class io.confluent.security.auth.store.data.UserValue
 
equals(Object) - Method in class io.confluent.security.auth.store.data.AclBindingKey
 
equals(Object) - Method in class io.confluent.security.auth.store.data.AclBindingValue
 
equals(Object) - Method in class io.confluent.security.auth.store.data.AuthKey
 
equals(Object) - Method in class io.confluent.security.auth.store.data.AuthValue
 
equals(Object) - Method in class io.confluent.security.auth.store.data.IdentityPoolKey
 
equals(Object) - Method in class io.confluent.security.auth.store.data.IdentityPoolValue
 
equals(Object) - Method in class io.confluent.security.auth.store.data.JwtIssuerKey
 
equals(Object) - Method in class io.confluent.security.auth.store.data.JwtIssuerValue
 
equals(Object) - Method in class io.confluent.security.auth.store.data.RoleBindingKey
 
equals(Object) - Method in class io.confluent.security.auth.store.data.RoleBindingValue
 
equals(Object) - Method in class io.confluent.security.auth.store.data.StatusKey
 
equals(Object) - Method in class io.confluent.security.auth.store.data.StatusValue
 
equals(Object) - Method in class io.confluent.security.auth.store.data.UserKey
 
equals(Object) - Method in class io.confluent.security.auth.store.data.UserValue
 
equals(Object) - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
 
error() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore.DeserializerErrorForKey
 
error() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore.DeserializerErrorForValue
 
error() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment
 
errorCode() - Method in enum io.confluent.security.store.kafka.coordinator.MetadataServiceAssignment.AssignmentError
 
errorMessage() - Method in class io.confluent.security.auth.store.data.StatusValue
 
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 - Variable in class io.confluent.security.store.kafka.clients.KafkaReader.PartitionState
 
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.DefaultAuthCache
 
fail(String) - Method in interface io.confluent.security.auth.store.external.ExternalStoreListener
Indicates that the connection to the external store has failed.
fail(int, String) - Method in interface io.confluent.security.store.KeyValueStore
Sets local error for the store with the specified error message.
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.
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
 
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns RBAC or ACL rule that matches the specified action.
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.DefaultAuthCache
 

G

generateConfig(Map<String, ?>) - Method in class io.confluent.security.auth.dataplane.JwtAuthenticatorConfig
 
generationId() - Method in class io.confluent.security.auth.store.data.StatusValue
 
generationIdDuringRead() - Method in class io.confluent.security.store.kafka.clients.CachedRecord
 
get(AuthKey) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
get(K) - Method in interface io.confluent.security.store.KeyValueStore
Returns the current value associated with key if it exists or null otherwise.
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
 
getInstance(String) - Static method in interface io.confluent.security.auth.metadata.AuthStore
 
getMessage() - Method in class io.confluent.security.auth.metadata.AuthCache.Result
Any message provided as part of the check
getSupportedCipherSuites() - Method in class io.confluent.security.auth.utils.ConfigurableSslSocketFactory
 
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 interface io.confluent.security.auth.metadata.AuthCache
Returns the groups of the provided user principal.
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.DefaultAuthCache
Returns the groups of the provided user principal.
groups() - Method in class io.confluent.security.auth.store.data.UserValue
 

H

handle(Callback[]) - Method in class io.confluent.security.auth.provider.ldap.LdapAuthenticateCallbackHandler
 
handle(Callback[]) - Method in class io.confluent.security.auth.provider.oauth.EnhancedOAuthBearerValidatorCallbackHandler
 
hashCode() - Method in class io.confluent.security.auth.store.data.AclBindingKey
 
hashCode() - Method in class io.confluent.security.auth.store.data.AclBindingValue
 
hashCode() - Method in class io.confluent.security.auth.store.data.AuthKey
Using entryType().name() to compute hashCode, so that hashCode() is constant across executions.
hashCode() - Method in class io.confluent.security.auth.store.data.AuthValue
 
hashCode() - Method in class io.confluent.security.auth.store.data.IdentityPoolKey
 
hashCode() - Method in class io.confluent.security.auth.store.data.IdentityPoolValue
 
hashCode() - Method in class io.confluent.security.auth.store.data.JwtIssuerKey
 
hashCode() - Method in class io.confluent.security.auth.store.data.JwtIssuerValue
 
hashCode() - Method in class io.confluent.security.auth.store.data.RoleBindingKey
 
hashCode() - Method in class io.confluent.security.auth.store.data.RoleBindingValue
 
hashCode() - Method in class io.confluent.security.auth.store.data.StatusKey
 
hashCode() - Method in class io.confluent.security.auth.store.data.StatusValue
 
hashCode() - Method in class io.confluent.security.auth.store.data.UserKey
 
hashCode() - Method in class io.confluent.security.auth.store.data.UserValue
 
hashCode() - Method in class io.confluent.security.store.kafka.coordinator.NodeMetadata
 
healthcheck() - Method in interface io.confluent.security.auth.metadata.AuthCache
health check method which returns the health of the underlying auth store
healthcheck() - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
healthy() - Static method in class io.confluent.security.auth.metadata.AuthCache.Result
 
healthy(String) - Static method in class io.confluent.security.auth.metadata.AuthCache.Result
 

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.DefaultAuthCache
 
IdentityPoolKey - Class in io.confluent.security.auth.store.data
 
IdentityPoolKey(String) - Constructor for class io.confluent.security.auth.store.data.IdentityPoolKey
 
identityPools() - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
IdentityPoolValue - Class in io.confluent.security.auth.store.data
 
IdentityPoolValue(long, String, String, String, String, String) - Constructor for class io.confluent.security.auth.store.data.IdentityPoolValue
 
IdentityPoolValue(long, String, String, String, String) - Constructor for class io.confluent.security.auth.store.data.IdentityPoolValue
 
IdentityPoolValue(IdentityPool) - Constructor for class io.confluent.security.auth.store.data.IdentityPoolValue
 
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.
INSTANCES - Static variable in interface io.confluent.security.auth.metadata.AuthStore
 
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.provider.oauth - package io.confluent.security.auth.provider.oauth
 
io.confluent.security.auth.store.cache - package io.confluent.security.auth.store.cache
 
io.confluent.security.auth.store.data - package io.confluent.security.auth.store.data
 
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
 
isConfluentCloud - Variable in class io.confluent.security.auth.provider.ConfluentProvider
 
isConfluentCloud() - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
isForKey() - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde.DeserializationError
 
isHealthy() - Method in class io.confluent.security.auth.metadata.AuthCache.Result
 
isMasterWriter() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore
 
isMasterWriter() - Method in interface io.confluent.security.auth.metadata.AuthStore
Returns true if this node is currently the master writer.
isMasterWriter() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
isMasterWriter() - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
 
issuer() - Method in class io.confluent.security.auth.store.data.IdentityPoolValue
 
issuer() - Method in class io.confluent.security.auth.store.data.JwtIssuerKey
 
isSuperUser(KafkaPrincipal, Scope) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 

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.DefaultAuthCache
 
jsonWebKeySets() - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
JWT_AUTHENTICATOR_CONFIG_URL - Static variable in class io.confluent.security.auth.dataplane.JwtAuthenticatorConfig
 
JWT_AUTHENTICATOR_CONFIG_URL_DOC - Static variable in class io.confluent.security.auth.dataplane.JwtAuthenticatorConfig
 
JWT_ISSUER_COUNT - Static variable in class io.confluent.security.auth.utils.AuthStoreMetrics
 
JwtAuthenticatorConfig - Class in io.confluent.security.auth.dataplane
 
JwtIssuerAuthCache - Class in io.confluent.security.auth.dataplane
Fetches Signature Verification key information from AuthCache according to issuer information from the token claim.
JwtIssuerAuthCache.Builder - Class in io.confluent.security.auth.dataplane
 
JwtIssuerKey - Class in io.confluent.security.auth.store.data
 
JwtIssuerKey(String) - Constructor for class io.confluent.security.auth.store.data.JwtIssuerKey
 
JwtIssuerValue - Class in io.confluent.security.auth.store.data
 
JwtIssuerValue(JsonWebKeySet) - Constructor for class io.confluent.security.auth.store.data.JwtIssuerValue
 

K

KafkaAuthStore - Class in io.confluent.security.auth.store.kafka
 
KafkaAuthStore(boolean, Scope, ConfluentAuthorizerServerInfo) - Constructor for class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
KafkaAuthStore(RbacRoles, Time, Scope, ConfluentAuthorizerServerInfo, int) - Constructor for class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
KafkaAuthWriter - Class in io.confluent.security.auth.store.kafka
Writer that initiates updates to metadata.
KafkaAuthWriter(String, int, KafkaStoreConfig, Producer<AuthKey, AuthValue>, Supplier<AdminClient>, DefaultAuthCache, StatusListener, CompletableFuture<Void>, Time) - Constructor for class io.confluent.security.auth.store.kafka.KafkaAuthWriter
 
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, Consumer<K, V>, KeyValueStore<K, V>, ConsumerListener<K, V>, StatusListener, KafkaStoreConfig, Time) - Constructor for class io.confluent.security.store.kafka.clients.KafkaReader
 
KafkaReader.PartitionState - Class in io.confluent.security.store.kafka.clients
 
KafkaStoreConfig - Class in io.confluent.security.store.kafka
 
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
 
KafkaVerificationKeyResolver - Class in io.confluent.security.auth.dataplane
 
KafkaVerificationKeyResolver(String, String) - Constructor for class io.confluent.security.auth.dataplane.KafkaVerificationKeyResolver
 
key() - Method in class io.confluent.security.store.kafka.clients.CachedRecord
 
keyResolver(Collection<Constraint>) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache
Returns Signature Verification Key identified by AuthCache
keys() - Method in class io.confluent.security.auth.store.data.JwtIssuerValue
 
keySerde() - Static method in class io.confluent.security.auth.dataplane.DataplaneAuthStore
 
KeyValueStore<K,V> - Interface in io.confluent.security.store
Key value store implemented by in-memory cache backed with data from a potentially partitioned source like a Kafka topic.
knownScopes() - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns all Scopes known by the backend, regardless of whether or not they actually exist.
knownScopes() - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 

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
 
LdapStore - Class in io.confluent.security.auth.provider.ldap
 
LdapStore(AuthCache, KafkaAuthWriter, Time) - Constructor for class io.confluent.security.auth.provider.ldap.LdapStore
 

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.DefaultAuthCache
 
map(String) - Method in interface io.confluent.security.store.KeyValueStore
 
masterWriterId() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore
 
masterWriterId() - Method in interface io.confluent.security.auth.metadata.AuthStore
Returns the broker id of the master writer.
masterWriterId() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
masterWriterUrl(String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore
 
masterWriterUrl(String) - Method in interface io.confluent.security.auth.metadata.AuthStore
Returns the URL of the master writer node for the specified protocol.
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.ConfluentProvider
 
metadata() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
 
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
 
metadataServerAdvertisedListeners() - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
Currently we don't enable MDS for DataPlane RBAC.
metadataServerAdvertisedListeners() - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
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
 
MetadataStoreStatus - Enum in io.confluent.security.store
 
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.store.kafka.KafkaAuthStore
 
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(String) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder
 
name() - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache
newGauge(String, String, String, Map<String, String>, Supplier<T>) - Static method in class io.confluent.security.auth.utils.MetricsUtils
 
newInstance(Map<String, ?>) - Static method in class io.confluent.security.auth.dataplane.JwtAuthenticatorConfig
 
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
 
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.
onConsume(long, boolean) - Method in class io.confluent.security.store.kafka.clients.KafkaReader.PartitionState
 
onConsumerRecord(ConsumerRecord<AuthKey, AuthValue>, AuthValue) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore
 
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
onJoinComplete(int, String, String, ByteBuffer) - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
 
onJoinPrepare(Timer, int, String) - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
 
onLeaderElected(String, String, List<JoinGroupResponseData.JoinGroupResponseMember>, boolean) - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
 
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() - 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.
orgId() - Method in class io.confluent.security.auth.store.data.IdentityPoolValue
 

P

partition() - Method in class io.confluent.security.auth.store.data.StatusKey
 
partitionReadyFutures() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthReader
We are not expecting Status messages for auth topic partitions from sync pipeline.
partitionReadyFutures() - Method in class io.confluent.security.store.kafka.clients.KafkaReader
 
partitionStates - Variable in class io.confluent.security.store.kafka.clients.KafkaReader
 
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
 
policy() - Method in class io.confluent.security.auth.store.data.IdentityPoolValue
 
poolId() - Method in class io.confluent.security.auth.store.data.IdentityPoolKey
 
PREFIX - Static variable in class io.confluent.security.store.kafka.KafkaStoreConfig
 
prepareReaderStartupState - Variable in class io.confluent.security.store.kafka.clients.KafkaReader
 
principal() - Method in class io.confluent.security.auth.store.data.RoleBindingKey
 
principal() - Method in class io.confluent.security.auth.store.data.UserKey
 
processConsumerRecord(ConsumerRecord<K, V>) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthReader
 
processConsumerRecord(ConsumerRecord<K, V>) - Method in class io.confluent.security.store.kafka.clients.KafkaReader
 
producerConfigs(String) - Method in class io.confluent.security.store.kafka.KafkaStoreConfig
 
PROTOCOL - Static variable in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
 
protocolType() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
 
PROVIDER_NAME - Static variable in class io.confluent.security.auth.dataplane.DataplaneProvider
 
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.ConfluentProvider
 
providerName() - Method in class io.confluent.security.auth.provider.ldap.LdapGroupProvider
 
put(AuthKey, AuthValue) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
put(K, V) - Method in interface io.confluent.security.store.KeyValueStore
Updates the entry for key with the specified value.

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 interface io.confluent.security.auth.metadata.AuthCache
Returns the role bindings at the specified scope.
rbacRoleBindings(Set<Scope>) - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns all the role bindings from a set of scopes.
rbacRoleBindings(RoleBindingFilter) - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns role bindings that match the specified filter.
rbacRoleBindings(KafkaPrincipal) - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns role bindings for the given principal and the principals groups across all known scopes.
rbacRoleBindings(KafkaPrincipal, Set<Scope>) - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns role bindings for the given principal and the principals groups limited to the defined set of Scopes.
rbacRoleBindings(Scope) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
rbacRoleBindings(Set<Scope>) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
rbacRoleBindings(RoleBindingFilter) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
rbacRoleBindings(KafkaPrincipal) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
rbacRoleBindings(KafkaPrincipal, Set<Scope>) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
rbacRoles() - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns the RBAC role definitions associated with this cache.
rbacRoles() - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
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
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
 
refreshTimeout - Variable in class io.confluent.security.store.kafka.KafkaStoreConfig
 
rejoinNeededOrPending() - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
 
remove(AuthKey) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
remove(K) - Method in interface io.confluent.security.store.KeyValueStore
Removes the entry corresponding to the key if it is present in the store.
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
 
removeInstance(String, AuthStore, Logger) - Static method in interface io.confluent.security.auth.metadata.AuthStore
 
removeJwtIssuer(Optional<Principal>, String, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
 
removeJwtIssuer(Optional<Principal>, 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
 
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 interface io.confluent.security.auth.metadata.AuthWriter
Removes resources from an existing role binding.
removeResourceRoleBinding(KafkaPrincipal, String, Scope, Collection<ResourcePatternFilter>) - Method in interface io.confluent.security.auth.metadata.AuthWriter
 
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 interface io.confluent.security.auth.metadata.AuthWriter
Removes a role binding.
removeRoleBinding(KafkaPrincipal, String, Scope) - Method in interface io.confluent.security.auth.metadata.AuthWriter
 
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) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
 
replaceIdentityPool(Optional<Principal>, String, int, String, String, String, String, String, String) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
 
replaceJwtIssuer(Optional<Principal>, String, JsonWebKeySet, String) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthWriter
 
replaceJwtIssuer(Optional<Principal>, String, JsonWebKeySet, 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 interface io.confluent.security.auth.metadata.AuthWriter
Sets resources for an existing role binding.
replaceResourceRoleBinding(KafkaPrincipal, String, Scope, Collection<ResourcePattern>) - Method in interface io.confluent.security.auth.metadata.AuthWriter
 
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.
resolveKey(JsonWebSignature, List<JsonWebStructure>) - Method in class io.confluent.security.auth.dataplane.KafkaVerificationKeyResolver
 
resourcePattern() - Method in class io.confluent.security.auth.store.data.AclBindingKey
 
resources() - Method in class io.confluent.security.auth.store.data.RoleBindingValue
 
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
 
retryTimeout - Variable in class io.confluent.security.store.kafka.KafkaStoreConfig
 
role() - Method in class io.confluent.security.auth.store.data.RoleBindingKey
 
RoleBindingKey - Class in io.confluent.security.auth.store.data
 
RoleBindingKey(KafkaPrincipal, String, Scope) - Constructor for class io.confluent.security.auth.store.data.RoleBindingKey
 
RoleBindingValue - Class in io.confluent.security.auth.store.data
 
RoleBindingValue(Collection<ResourcePattern>) - Constructor for class io.confluent.security.auth.store.data.RoleBindingValue
 
rootScope() - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns the root scope of this cache.
rootScope() - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
run() - Method in class io.confluent.security.store.kafka.clients.KafkaReader
 

S

scope() - Method in class io.confluent.security.auth.store.data.AclBindingKey
 
scope() - Method in class io.confluent.security.auth.store.data.RoleBindingKey
 
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
 
searchAndProcessResults() - Method in class io.confluent.security.auth.provider.ldap.LdapGroupManager
 
searchAndProcessResults(boolean) - Method in class io.confluent.security.auth.provider.ldap.LdapGroupManager
 
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
 
serviceAccount() - Method in class io.confluent.security.auth.store.data.IdentityPoolValue
 
sessionUuid(String) - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache.Builder
 
sessionUuid() - Method in class io.confluent.security.auth.dataplane.JwtIssuerAuthCache
 
setKafkaMetrics(Metrics) - Method in class io.confluent.security.auth.provider.ConfluentProvider
 
start(ConfluentAuthorizerServerInfo, Map<String, ?>) - 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.DataplaneAuthStore
 
startReader() - Method in interface io.confluent.security.auth.metadata.AuthStore
Starts the metadata reader and returns a completion stage that is completed when existing metadata from the store has been loaded into the cache.
startReader() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
startService(Collection<URL>) - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore
 
startService(Collection<URL>) - Method in interface io.confluent.security.auth.metadata.AuthStore
Starts the metadata coordinator and writer.
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.DefaultAuthCache
 
status() - Method in class io.confluent.security.auth.store.data.StatusValue
 
status(int) - Method in interface io.confluent.security.store.KeyValueStore
Status of the metadata store for the specified partition
StatusKey - Class in io.confluent.security.auth.store.data
 
StatusKey(int) - Constructor for class io.confluent.security.auth.store.data.StatusKey
 
StatusListener - Interface in io.confluent.security.store.kafka.clients
Interface to listener for failure status of KafkaStore readers and writers
StatusValue - Class in io.confluent.security.auth.store.data
 
StatusValue(MetadataStoreStatus, int, Integer, String) - Constructor for class io.confluent.security.auth.store.data.StatusValue
 
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.
subjectClaim() - Method in class io.confluent.security.auth.store.data.IdentityPoolValue
 

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.security.auth.dataplane.DataplaneAuthStore.DeserializerErrorForKey
 
toString() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore.DeserializerErrorForValue
 
toString() - Method in class io.confluent.security.auth.metadata.AuthCache.Result
 
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.auth.store.data.AclBindingKey
 
toString() - Method in class io.confluent.security.auth.store.data.AclBindingValue
 
toString() - Method in class io.confluent.security.auth.store.data.IdentityPoolKey
 
toString() - Method in class io.confluent.security.auth.store.data.IdentityPoolValue
 
toString() - Method in class io.confluent.security.auth.store.data.JwtIssuerKey
 
toString() - Method in class io.confluent.security.auth.store.data.JwtIssuerValue
 
toString() - Method in class io.confluent.security.auth.store.data.RoleBindingKey
 
toString() - Method in class io.confluent.security.auth.store.data.RoleBindingValue
 
toString() - Method in class io.confluent.security.auth.store.data.StatusKey
 
toString() - Method in class io.confluent.security.auth.store.data.StatusValue
 
toString() - Method in class io.confluent.security.auth.store.data.UserKey
 
toString() - Method in class io.confluent.security.auth.store.data.UserValue
 
toString() - Method in class io.confluent.security.store.kafka.clients.DeserializationErrorHandlingJsonSerde.DeserializationError
 
toString() - Method in class io.confluent.security.store.kafka.clients.KafkaReader.PartitionState
 
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.DefaultAuthCache
 
totalIdentityPools() - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
totalJwtIssuers() - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
totalRbacAccessRules() - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
totalRoleBindings() - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
trustCache() - Method in class io.confluent.security.auth.dataplane.DataplaneAuthStore
 
trustCache() - Method in interface io.confluent.security.auth.metadata.AuthStore
Returns a trust cache that stores all OAuth related metadata from the auth topic.
trustCache() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 

U

unhealthy(String) - Static method in class io.confluent.security.auth.metadata.AuthCache.Result
 
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.
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
 
UserKey - Class in io.confluent.security.auth.store.data
 
UserKey(KafkaPrincipal) - Constructor for class io.confluent.security.auth.store.data.UserKey
 
userMetadata(KafkaPrincipal) - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns metadata for the specified user principal if available or null if user is not known.
userMetadata(KafkaPrincipal) - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
users() - Method in interface io.confluent.security.auth.metadata.AuthCache
Returns user metadata for all users.
users() - Method in class io.confluent.security.auth.store.cache.DefaultAuthCache
 
UserValue - Class in io.confluent.security.auth.store.data
 
UserValue(Collection<KafkaPrincipal>) - Constructor for class io.confluent.security.auth.store.data.UserValue
 
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.security.auth.dataplane.DataplaneProvider
 
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.security.auth.provider.ConfluentProvider
Returns true if this broker is running the centralized Metadata Service in the embedded MetadataServer as indicated by MetadataServerConfig.METADATA_SERVER_LISTENERS_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() - 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.store.data.AuthEntryType
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.
valueOf(String) - Static method in enum io.confluent.security.store.MetadataStoreStatus
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.store.data.AuthEntryType
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.
values() - Static method in enum io.confluent.security.store.MetadataStoreStatus
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
 
verify(char[], char[]) - Method in interface io.confluent.security.auth.metadata.PasswordVerifier
 
version() - Method in class io.confluent.security.auth.store.data.IdentityPoolValue
 
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.
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.DataplaneAuthStore
 
writer() - Method in interface io.confluent.security.auth.metadata.AuthStore
Returns a writer instance that can be used to update this store.
writer() - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
 
Writer - Interface in io.confluent.security.store.kafka.clients
 
writerBrokerId() - Method in class io.confluent.security.auth.store.data.StatusValue
 
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