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

A

addTopic(TopicSpec) - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager
 
allowed - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig.DefaultTopics
 
ALLOWED_RESULTS - Static variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
AlterConfigsRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
AlterConfigsRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.AlterConfigsRequestAuditExtractor
 
AlterMirrorsRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
AlterMirrorsRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.AlterMirrorsRequestAuditExtractor
 
areEquivalent(ConfluentResourceName, ConfluentResourceName) - Method in class io.confluent.crn.ConfluentServerCrnAuthority
 
AUDIT_CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
AUDIT_CLOUD_EVENT_ENCODING_DOC - Static variable in class io.confluent.security.audit.AuditLogConfig
 
AUDIT_LOG_FALLBACK_RATE_MINUTE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
 
AUDIT_LOG_RATE_MINUTE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
 
AuditExtractorOptions - Class in io.confluent.security.audit.kafka
 
AuditExtractorOptions(ConfluentServerCrnAuthority, boolean) - Constructor for class io.confluent.security.audit.kafka.AuditExtractorOptions
 
auditLog(KafkaRequestEvent, AuditExtractorOptions, boolean, boolean, Struct, Result.Status, Struct, List<TypedCloudResourceRef>, String) - Static method in class io.confluent.security.audit.AuditLogUtils
 
AuditLogCategoryResultRouter - Class in io.confluent.security.audit.router
 
AuditLogCategoryResultRouter() - Constructor for class io.confluent.security.audit.router.AuditLogCategoryResultRouter
 
AuditLogConfig - Class in io.confluent.security.audit
 
AuditLogConfig(Map<String, ?>) - Constructor for class io.confluent.security.audit.AuditLogConfig
 
AuditLogOAuthUtils - Class in io.confluent.security.audit
 
AuditLogOAuthUtils() - Constructor for class io.confluent.security.audit.AuditLogOAuthUtils
 
AuditLogRouter - Class in io.confluent.security.audit.router
 
AuditLogRouter(AuditLogRouterJsonConfig, int) - Constructor for class io.confluent.security.audit.router.AuditLogRouter
 
AuditLogRouterJsonConfig - Class in io.confluent.security.audit.router
 
AuditLogRouterJsonConfig() - Constructor for class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
AuditLogRouterJsonConfig.Canonicalizer - Class in io.confluent.security.audit.router
Renames any legacy "other" category rule to a "management" rule, or drops the "other" category rule if both are present.
AuditLogRouterJsonConfig.DefaultTopics - Class in io.confluent.security.audit.router
 
AuditLogRouterJsonConfig.Destinations - Class in io.confluent.security.audit.router
 
AuditLogRouterJsonConfig.DestinationTopic - Class in io.confluent.security.audit.router
 
AuditLogRouterJsonConfig.Metadata - Class in io.confluent.security.audit.router
 
AuditLogRouterResult - Enum in io.confluent.security.audit.router
 
AuditLogRouterUtils - Class in io.confluent.security.audit.router
 
AuditLogRouterUtils() - Constructor for class io.confluent.security.audit.router.AuditLogRouterUtils
 
AuditLogRouterUtils.RequestNameOverrides - Enum in io.confluent.security.audit.router
 
AuditLogUtils - Class in io.confluent.security.audit
 
AuditLogUtils() - Constructor for class io.confluent.security.audit.AuditLogUtils
 
AUTHENTICATION_AUDIT_LOG_FAILURE_RATE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
 
AUTHENTICATION_AUDIT_LOG_RATE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
 
AUTHENTICATION_CATEGORY - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 
AUTHENTICATION_EVENT_NAME - Static variable in class io.confluent.security.audit.AuditLogUtils
 
AUTHENTICATION_FAILED_EVENT_USER - Static variable in class io.confluent.security.audit.AuditLogUtils
 
AUTHENTICATION_MESSAGE_TYPE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
authenticationEvent(ConfluentAuthenticationEvent, ConfluentServerCrnAuthority) - Static method in class io.confluent.security.audit.AuditLogUtils
 
authenticationEvent(ConfluentAuthenticationEvent, KafkaPrincipal, ConfluentServerCrnAuthority, boolean) - Static method in class io.confluent.security.audit.AuditLogUtils
 
AUTHORITY_NAME - Static variable in class io.confluent.crn.ConfluentCloudCrnAuthority
 
AUTHORIZATION_AUDIT_LOG_FAILURE_RATE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
 
AUTHORIZATION_AUDIT_LOG_RATE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
 
AUTHORIZATION_MESSAGE_TYPE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
authorizationEvent(ConfluentAuthorizationEvent, ConfluentServerCrnAuthority) - Static method in class io.confluent.security.audit.AuditLogUtils
 
authorizationEvent(ConfluentAuthorizationEvent, KafkaPrincipal, ConfluentServerCrnAuthority, boolean) - Static method in class io.confluent.security.audit.AuditLogUtils
 
AUTHORIZE_CATEGORY - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 

B

BOOTSTRAP_SERVERS_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
BOOTSTRAP_SERVERS_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
BOOTSTRAP_SERVERS_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
bootstrapServers() - Method in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
bootstrapServers - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig.Destinations
 
build() - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager.Builder
 
build() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Builder
 
builder() - Static method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 

C

CACHE_ENTRIES_CONFIG - Static variable in class io.confluent.crn.CrnAuthorityConfig
 
CACHE_ENTRIES_DEFAULT - Static variable in class io.confluent.crn.CrnAuthorityConfig
 
CACHE_ENTRIES_DOC - Static variable in class io.confluent.crn.CrnAuthorityConfig
 
canonicalCrn(Scope, ResourcePattern) - Method in class io.confluent.crn.ConfluentCloudCrnAuthority
 
canonicalCrn(Scope, ResourcePattern) - Method in class io.confluent.crn.ConfluentServerCrnAuthority
This is the base canonicalCrn method.
canonicalCrn(Scope) - Method in class io.confluent.crn.ConfluentServerCrnAuthority
 
canonicalCrn(String) - Method in class io.confluent.crn.ConfluentServerCrnAuthority
 
canonicalCrn(ConfluentResourceName) - Method in class io.confluent.crn.ConfluentServerCrnAuthority
 
Canonicalizer() - Constructor for class io.confluent.security.audit.router.AuditLogRouterJsonConfig.Canonicalizer
 
CATEGORIES - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 
category(AuditLogEntry) - Static method in class io.confluent.security.audit.router.AuditLogRouterUtils
 
category(String) - Static method in class io.confluent.security.audit.router.AuditLogRouterUtils
 
category - Variable in enum io.confluent.security.audit.router.AuditLogRouterUtils.RequestNameOverrides
 
check() - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager
 
checkTopics() - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager
 
clientProperties(Set<String>, String) - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
clientProperties(Set<String>) - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
close(String) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
close() - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
close() - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
 
close() - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager
 
CLOUD_CLUSTER_RESOURCE_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
CLOUD_CLUSTER_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
cloudResourceRef(List<TypedCloudResourceRef>) - Static method in class io.confluent.security.audit.AuditLogUtils
 
CLUSTER_TYPE_BY_KEY - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
config() - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
 
config - Variable in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Builder
 
config() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
configure(Map<String, ?>) - Method in class io.confluent.crn.ConfluentServerCrnAuthority
 
configure(Map<String, ?>) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
The provider is configured and started during ConfluentAuditLogProvider.start(Map) to get access to the interbroker properties.
configure(Map<String, ?>) - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
 
ConfluentAuditLogProvider - Class in io.confluent.security.audit.provider
 
ConfluentAuditLogProvider() - Constructor for class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
ConfluentAuditLogProvider.AuditLogMetrics - Class in io.confluent.security.audit.provider
 
ConfluentCloudCrnAuthority - Class in io.confluent.crn
 
ConfluentCloudCrnAuthority() - Constructor for class io.confluent.crn.ConfluentCloudCrnAuthority
 
ConfluentCloudCrnAuthority(int) - Constructor for class io.confluent.crn.ConfluentCloudCrnAuthority
 
ConfluentServerCrnAuthority - Class in io.confluent.crn
This CrnAuthority handles the resource types present in the Confluent Platform
ConfluentServerCrnAuthority(String, int) - Constructor for class io.confluent.crn.ConfluentServerCrnAuthority
 
ConfluentServerCrnAuthority() - Constructor for class io.confluent.crn.ConfluentServerCrnAuthority
 
CONNECT_CLUSTER_KEY - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
CONNECT_CLUSTER_RESOURCE_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
CONNECT_CLUSTER_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
CONSUME_CATEGORY - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 
convert(AuditLogRouterJsonConfig) - Method in class io.confluent.security.audit.router.AuditLogRouterJsonConfig.Canonicalizer
 
CreateAclsRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
CreateAclsRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.CreateAclsRequestAuditExtractor
 
CreateClusterLinksAuditExtractor - Class in io.confluent.security.audit.kafka
 
CreateClusterLinksAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.CreateClusterLinksAuditExtractor
 
CreatePartitionsRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
CreatePartitionsRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.CreatePartitionsRequestAuditExtractor
 
CreateTopicsRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
CreateTopicsRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.CreateTopicsRequestAuditExtractor
 
CRN_AUTHORITY_TYPE_CONFIG - Static variable in class io.confluent.crn.CrnAuthorityConfig
 
CRN_AUTHORITY_TYPE_DEFAULT - Static variable in class io.confluent.crn.CrnAuthorityConfig
 
CRN_AUTHORITY_TYPE_DOC - Static variable in class io.confluent.crn.CrnAuthorityConfig
 
crnAuthority() - Method in class io.confluent.security.audit.kafka.AuditExtractorOptions
 
CrnAuthorityConfig - Class in io.confluent.crn
 
CrnAuthorityConfig(Map<?, ?>) - Constructor for class io.confluent.crn.CrnAuthorityConfig
 

D

DEFAULT_AUDIT_CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
DEFAULT_ENABLED_CATEGORIES - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 
DEFAULT_EVENT_EXPORTER_CLASS_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
DEFAULT_EVENT_LOGGER_LOG_BLOCKING_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
DEFAULT_REQUEST_TIMEOUT_MS - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
DEFAULT_RETENTION_MS - Static variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
DEFAULT_ROUTER_CACHE_ENTRIES - Static variable in class io.confluent.security.audit.AuditLogConfig
 
DEFAULT_TOPIC - Static variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
DEFAULT_TOPIC - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
DEFAULT_TOPIC_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
DEFAULT_TOPIC_CREATE_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
DEFAULT_TOPIC_CREATE_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
DEFAULT_TOPIC_PARTITIONS_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
DEFAULT_TOPIC_PARTITIONS_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
DEFAULT_TOPIC_REPLICAS_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
DEFAULT_TOPIC_RETENTION_BYTES_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
DEFAULT_TOPIC_RETENTION_BYTES_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
DEFAULT_TOPIC_RETENTION_MS_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
DEFAULT_TOPIC_RETENTION_MS_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
DEFAULT_TOPIC_ROLL_MS_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
DEFAULT_TOPIC_ROLL_MS_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
DEFAULT_V2_TOPIC - Static variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
DEFAULT_V2_TOPIC_ROUTE - Static variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
defaultConfig() - Static method in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
This config is used if the AuditLogging feature is not configured.
defaultRoute(String, AuditLogRouterResult) - Method in class io.confluent.security.audit.router.AuditLogRouter
 
defaultTopicConfig() - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
defaultTopics - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
DefaultTopics(String, String) - Constructor for class io.confluent.security.audit.router.AuditLogRouterJsonConfig.DefaultTopics
 
DeleteAclsRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
DeleteAclsRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.DeleteAclsRequestAuditExtractor
 
DeleteClusterLinksRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
DeleteClusterLinksRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.DeleteClusterLinksRequestAuditExtractor
 
DeleteGroupsRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
DeleteGroupsRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.DeleteGroupsRequestAuditExtractor
 
DeleteTopicsRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
DeleteTopicsRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.DeleteTopicsRequestAuditExtractor
 
denied - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig.DefaultTopics
 
DESCRIBE_CATEGORY - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 
destinations - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
Destinations(List<String>) - Constructor for class io.confluent.security.audit.router.AuditLogRouterJsonConfig.Destinations
 
DestinationTopic(long) - Constructor for class io.confluent.security.audit.router.AuditLogRouterJsonConfig.DestinationTopic
 

E

emit(Event) - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
 
emit(Event, Runnable, Runnable) - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
 
ensureTopics() - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager
 
ENVIRONMENT_RESOURCE_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
ENVIRONMENT_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
equals(Object) - Method in class io.confluent.crn.ScopedResourcePattern
 
equals(Object) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
EVENT_EXPORTER_CLASS_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
EVENT_LOGGER_LOG_BLOCKING_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
EVENT_LOGGER_LOG_BLOCKING_CONFIG_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
excludedPrincipals - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
externalIdentityId(KafkaPrincipal) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.AlterConfigsRequestAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.AlterMirrorsRequestAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.CreateAclsRequestAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.CreateClusterLinksAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.CreatePartitionsRequestAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.CreateTopicsRequestAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.DeleteAclsRequestAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.DeleteClusterLinksRequestAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.DeleteGroupsRequestAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.DeleteTopicsRequestAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.FetchRequestAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.IncrementalAlterRequestAuditExtractor
 
extract(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.ProduceRequestAuditExtractor
 
extractAuditLog(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.kafka.KafkaRequestToAuditEntry
 

F

FetchRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
FetchRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.FetchRequestAuditExtractor
 
FLINK_CLUSTER_KEY - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
FLINK_CLUSTER_RESOURCE_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
FLINK_CLUSTER_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
FLINK_REGION_RESOURCE_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
FLINK_REGION_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 

G

getEventLogger() - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
getTopicSpecs() - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
GROUP_NAME - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
 

H

hasAuthorizationFailure(short) - Static method in class io.confluent.security.audit.AuditLogUtils
 
hashCode() - Method in class io.confluent.crn.ScopedResourcePattern
 
hashCode() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
HEARTBEAT_CATEGORY - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 

I

IDENTITY_POOL_ID_KEY - Static variable in class io.confluent.security.audit.AuditLogOAuthUtils
 
IDENTITY_PROVIDER_KEY - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
IDENTITY_PROVIDER_RESOURCE_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
IDENTITY_PROVIDER_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
IncrementalAlterRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
IncrementalAlterRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.IncrementalAlterRequestAuditExtractor
 
initExecutor() - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
INTERBROKER_CATEGORY - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 
io.confluent.crn - package io.confluent.crn
 
io.confluent.security.audit - package io.confluent.security.audit
 
io.confluent.security.audit.kafka - package io.confluent.security.audit.kafka
 
io.confluent.security.audit.provider - package io.confluent.security.audit.provider
 
io.confluent.security.audit.router - package io.confluent.security.audit.router
 
io.confluent.security.audit.telemetry.exporter - package io.confluent.security.audit.telemetry.exporter
 
isEventLoggerReady() - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
isEventRoutable(ConfluentAuthorizationEvent) - Method in class io.confluent.security.audit.router.AuditLogRouter
 

K

KAFKA_CLUSTER_KEY - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
KAFKA_CLUSTER_RESOURCE_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
KAFKA_CLUSTER_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
KAFKA_EXPORTER_PREFIX - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
KAFKA_REQUEST_EVENT_AUDIT_LOG_FAILURE_RATE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
 
KAFKA_REQUEST_EVENT_AUDIT_LOG_RATE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
 
KAFKA_REQUEST_MESSAGE_TYPE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
kafkaInterBrokerClientConfig(Map<String, ?>) - Static method in class io.confluent.security.audit.AuditLogConfig
 
kafkaProducerOverrides() - Static method in class io.confluent.security.audit.AuditLogConfig
 
KafkaRequestToAuditEntry - Class in io.confluent.security.audit.kafka
 
KafkaRequestToAuditEntry() - Constructor for class io.confluent.security.audit.kafka.KafkaRequestToAuditEntry
 
KSQL_CLUSTER_KEY - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
KSQL_CLUSTER_RESOURCE_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
KSQL_CLUSTER_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 

L

lastMetadataRefresh() - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
 
load(String) - Static method in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
Throws IllegalArgumentException if the config is Invalid
logEvent(AuditEvent) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
logEvent(AuditEvent, boolean) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 

M

managedTopics() - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager
 
MANAGEMENT_CATEGORY - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 
maybeFetchIdentityInfo(KafkaPrincipal, Function<IdentityMetadata, Optional<String>>) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
 
maybeGetIdentityCRN(KafkaPrincipal, String) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
 
metadata - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
Metadata(String, String) - Constructor for class io.confluent.security.audit.router.AuditLogRouterJsonConfig.Metadata
 
METHOD_CATEGORIES - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 
methodName(ConfluentAuthorizationEvent) - Static method in class io.confluent.security.audit.AuditLogUtils
 
methodName(KafkaRequestEvent) - Static method in class io.confluent.security.audit.AuditLogUtils
 
metrics() - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
multiplePrincipal(KafkaPrincipal) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
 

N

name() - Method in class io.confluent.crn.ConfluentServerCrnAuthority
 
name - Variable in enum io.confluent.security.audit.router.AuditLogRouterUtils.RequestNameOverrides
 
name - Variable in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Builder
 
name() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
NETWORK_RESOURCE_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
NETWORK_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
newBuilder() - Static method in class io.confluent.security.audit.telemetry.exporter.TopicManager
 
NonBlockingKafkaExporter - Class in io.confluent.security.audit.telemetry.exporter
The NonBlockingKafkaExporter sends events to topics based on their content.
NonBlockingKafkaExporter() - Constructor for class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
 
NonBlockingKafkaExporterConfig - Class in io.confluent.security.audit.telemetry.exporter
 
NonBlockingKafkaExporterConfig(Map<String, ?>) - Constructor for class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 

O

omitClientAddress() - Method in class io.confluent.security.audit.kafka.AuditExtractorOptions
 
onUpdate(ClusterResource) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
ORGANIZATION_RESOURCE_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
ORGANIZATION_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
OTHER_CATEGORY - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
Deprecated.

P

partitions - Variable in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Builder
 
partitions() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
PATH_TYPE_SEPARATOR - Static variable in class io.confluent.crn.ConfluentCloudCrnAuthority
 
prefix - Variable in enum io.confluent.security.audit.router.AuditLogRouterUtils.RequestNameOverrides
 
PRODUCE_CATEGORY - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 
PRODUCER_PREFIX - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
ProduceRequestAuditExtractor - Class in io.confluent.security.audit.kafka
 
ProduceRequestAuditExtractor() - Constructor for class io.confluent.security.audit.kafka.ProduceRequestAuditExtractor
 
producerProperties() - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
providerConfigured(Map<String, ?>) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
putTopic(String, AuditLogRouterJsonConfig.DestinationTopic) - Method in class io.confluent.security.audit.router.AuditLogRouterJsonConfig.Destinations
 

R

reconcile() - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager
 
reconfigurableConfigs() - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
reconfigurableConfigs() - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
 
reconfigure(Map<String, ?>) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
reconfigure(Map<String, ?>) - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
 
replicationFactor - Variable in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Builder
 
replicationFactor() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
REQUEST_TIMEOUT_MS_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
REQUEST_TIMEOUT_MS_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
requestCrn(ConfluentServerCrnAuthority, KafkaRequestEvent) - Static method in class io.confluent.security.audit.AuditLogUtils
 
requestResourceCrn(ConfluentServerCrnAuthority, KafkaRequestEvent, ResourcePattern) - Static method in class io.confluent.security.audit.AuditLogUtils
 
resolveScopePattern(ConfluentResourceName) - Method in class io.confluent.crn.ConfluentServerCrnAuthority
 
resourceNameElement(AuditLogEntry) - Static method in class io.confluent.security.audit.AuditLogUtils
This returns the last element of the resource in the "resourceName" field.
resourcePattern() - Method in class io.confluent.crn.ScopedResourcePattern
 
resourceVersion - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig.Metadata
 
result(String) - Static method in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
retentionMs - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig.DestinationTopic
 
route(String, AuditLogRouterResult) - Method in class io.confluent.security.audit.router.AuditLogCategoryResultRouter
 
Router - Interface in io.confluent.security.audit.router
 
ROUTER_CACHE_ENTRIES_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
ROUTER_CACHE_ENTRIES_DOC - Static variable in class io.confluent.security.audit.AuditLogConfig
 
routeReady(Event) - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
 
routerJsonConfig() - Method in class io.confluent.security.audit.AuditLogConfig
 
routes - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 

S

SCHEMA_REGISTRY_CLUSTER_KEY - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
SCHEMA_REGISTRY_CLUSTER_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
SCHEMA_REGISTRY_RESOURCE_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
scope() - Method in class io.confluent.crn.ScopedResourcePattern
 
SCOPE_KEY_BY_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
SCOPE_RESOURCE_TYPE_BY_TYPE - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
SCOPE_RESOURCE_TYPES - Static variable in class io.confluent.crn.ConfluentServerCrnAuthority
 
ScopedResourcePattern - Class in io.confluent.crn
When dealing with resources in more than one scope, it is useful to be able to pass the Scope and ResourcePattern as a single object.
ScopedResourcePattern(Scope, ResourcePattern) - Constructor for class io.confluent.crn.ScopedResourcePattern
 
setAdminClientProperties(Properties) - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager.Builder
 
setAssignedPrincipal(AuthorizationInfo.Builder, KafkaPrincipal) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
 
setConfig(Map<String, String>) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Builder
 
setConfig(Map<String, String>) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
setDefaultTopicConfig(Map<String, String>) - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager.Builder
 
setDefaultTopicPartitions(Integer) - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager.Builder
 
setDefaultTopicReplicas(Integer) - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager.Builder
 
setIdentityField(AuthenticationInfo.Builder, KafkaPrincipal, String) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
 
setIdentityInformation(AuthenticationInfo.Builder, KafkaPrincipal, KafkaPrincipal, CrnAuthority) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
 
setIdentityInformation(AuthenticationInfo.Builder, AuthenticationException, CrnAuthority) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
 
setMetrics(Metrics) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
setName(String) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Builder
 
setName(String) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
setPartitions(int) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Builder
 
setPartitions(int) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
setReplicationFactor(int) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Builder
 
setReplicationFactor(int) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
setRoute(String, AuditLogRouterResult, String) - Method in class io.confluent.security.audit.router.AuditLogCategoryResultRouter
 
setSanitizer(UnaryOperator<AuditEvent>) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
setTimeOutMs(Integer) - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager.Builder
 
setTopicConfig(String, String) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Builder
 
setTopics(Map<String, TopicSpec>) - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager.Builder
 
setTopics(List<TopicSpec>) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Topics
 
start(Map<String, ?>) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
SUPPRESSED - Static variable in class io.confluent.security.audit.router.AuditLogRouter
 

T

toEventLoggerConfig(Map<String, ?>) - Static method in class io.confluent.security.audit.AuditLogConfig
 
toJsonString() - Method in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
topic(AuditLogEntry) - Method in class io.confluent.security.audit.router.AuditLogCategoryResultRouter
 
topic(AuditLogEntry) - Method in class io.confluent.security.audit.router.AuditLogRouter
 
topic(AuditLogEntry) - Method in interface io.confluent.security.audit.router.Router
Possibly return the name of a topic that this event should be routed to.
TOPIC_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_CONFIG_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_CREATE_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
TOPIC_CREATE_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_CREATE_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_MISSING_IN_REQUEST - Static variable in class io.confluent.security.audit.AuditLogUtils
 
TOPIC_PARTITIONS_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
TOPIC_PARTITIONS_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_PARTITIONS_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_PREFIX - Static variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
TOPIC_REPLICAS_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_REPLICAS_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_RETENTION_BYTES_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
TOPIC_RETENTION_BYTES_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_RETENTION_BYTES_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_RETENTION_MS_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
TOPIC_RETENTION_MS_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_RETENTION_MS_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_ROLL_MS_CONFIG - Static variable in class io.confluent.security.audit.AuditLogConfig
 
TOPIC_ROLL_MS_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
TOPIC_ROLL_MS_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
 
topicExists(String) - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager
 
topicManaged(String) - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager
 
TopicManager - Class in io.confluent.security.audit.telemetry.exporter
 
TopicManager(Properties, Map<String, String>, Integer, Integer, Integer, Map<String, TopicSpec>) - Constructor for class io.confluent.security.audit.telemetry.exporter.TopicManager
 
TopicManager.Builder - Class in io.confluent.security.audit.telemetry.exporter
 
topics - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig.Destinations
 
Topics() - Constructor for class io.confluent.security.audit.telemetry.exporter.TopicSpec.Topics
 
topics - Variable in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Topics
 
topics() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Topics
 
TopicSpec - Class in io.confluent.security.audit.telemetry.exporter
 
TopicSpec() - Constructor for class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
TopicSpec(String, int, int, Map<String, String>) - Constructor for class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
TopicSpec.Builder - Class in io.confluent.security.audit.telemetry.exporter
 
TopicSpec.Topics - Class in io.confluent.security.audit.telemetry.exporter
 
toString() - Method in class io.confluent.crn.ScopedResourcePattern
 
toString() - Method in class io.confluent.security.audit.kafka.AuditExtractorOptions
 
toString() - Method in class io.confluent.security.audit.router.AuditLogCategoryResultRouter
 
toString() - Method in class io.confluent.security.audit.router.AuditLogRouter
 
toString() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Topics
 
toString() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
 
typedCloudResourceRefList(KafkaRequestEvent) - Static method in class io.confluent.security.audit.AuditLogUtils
 

U

UNAUDITED - Static variable in class io.confluent.security.audit.router.AuditLogRouterUtils
 
updatedAt - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig.Metadata
 
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 

V

v2RequestMetadata(KafkaRequestEvent, AuditExtractorOptions) - Static method in class io.confluent.security.audit.AuditLogUtils
 
v2SchemaPrincipal(KafkaRequestEvent) - Static method in class io.confluent.security.audit.AuditLogUtils
 
validate(AuditLogRouterJsonConfig) - Static method in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
validateDefaultTopics(AuditLogRouterJsonConfig, Set<String>) - Static method in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
 
validateRoutes(AuditLogRouterJsonConfig, Set<String>) - Static method in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
 
valueOf(String) - Static method in enum io.confluent.security.audit.router.AuditLogRouterResult
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.security.audit.router.AuditLogRouterUtils.RequestNameOverrides
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.confluent.security.audit.router.AuditLogRouterResult
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.security.audit.router.AuditLogRouterUtils.RequestNameOverrides
Returns an array containing the constants of this enum type, in the order they are declared.
A B C D E F G H I K L M N O P R S T U V 
Skip navigation links