JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
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
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes