Index (ce-audit 8.0.5-ce API)

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

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 - Enum constant in enum class io.confluent.security.audit.router.AuditLogRouterResult
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
AUDIT_LOG_SIZE - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
AUDIT_LOGGER_CREATION_FAILURE - 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
AuditLogRateLimiter - Class in io.confluent.security.audit.provider
AuditLogRateLimiter() - Constructor for class io.confluent.security.audit.provider.AuditLogRateLimiter
AuditLogRateLimiter(Time) - Constructor for class io.confluent.security.audit.provider.AuditLogRateLimiter
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 Class 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 Class 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 - Variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig.Destinations
bootstrapServers() - Method in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
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
call() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
canonicalCrn(ConfluentResourceName) - Method in class io.confluent.crn.ConfluentServerCrnAuthority
canonicalCrn(Scope) - Method in class io.confluent.crn.ConfluentServerCrnAuthority
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(String) - 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 - Variable in enum class io.confluent.security.audit.router.AuditLogRouterUtils.RequestNameOverrides
category(AuditLogEntry) - Static method in class io.confluent.security.audit.router.AuditLogRouterUtils
category(String) - Static method in class io.confluent.security.audit.router.AuditLogRouterUtils
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>) - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
clientProperties(Set<String>, String) - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
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
close(String) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
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 - Variable in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Builder
config() - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporter
config() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
CONFIG_MAP_NAME_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
CONFIG_MAP_NAME_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
configure(Map<String, ?>) - Method in class io.confluent.crn.ConfluentServerCrnAuthority
configure(Map<String, ?>) - Method in class io.confluent.security.audit.provider.AuditLogRateLimiter
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
configureRemoteConfig(Map<String, ?>) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
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() - Constructor for class io.confluent.crn.ConfluentServerCrnAuthority
ConfluentServerCrnAuthority(String, int) - 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
createDefaultEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig) - Static method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
createEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig, String) - Static method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
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 - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.RemoteConfigConfiguration
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_MAX_RETRY_BACKOFF_MS - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
DEFAULT_NAMESPACE - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
DEFAULT_REFRESH_INTERVAL - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationConfig
DEFAULT_REQUEST_TIMEOUT_MS - Static variable in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
DEFAULT_RESOURCE_WATCHER_RETRY_COUNT - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
DEFAULT_RETENTION_MS - Static variable in class io.confluent.security.audit.router.AuditLogRouterJsonConfig
DEFAULT_RETRY_BACKOFF_MS - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
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
defineConfigs(ConfigDef) - Static method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationConfig
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
DENIED - Enum constant in enum class io.confluent.security.audit.router.AuditLogRouterResult
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
ENABLED_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.RemoteConfigConfiguration
ENABLED_CONFIG_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.RemoteConfigConfiguration
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

getAuditLogConfig() - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
getAuditLogRouterJsonConfig() - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
getConfig() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationSource: This method is used to get the current configuration before starting the polling.
getConfig() - Method in interface io.confluent.security.audit.telemetry.exporter.config.remote.RemoteConfigurationSource: Returns the latest received configuration from this source.
getCurrentResourceVersion() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesResourceMetadata
getEventLogger() - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
getLatestResourceVersion() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesResourceMetadata
getMaxRetryBackoffMs() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
getOrCreateWatcherSensor(String, Map<String, String>) - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
getRefreshIntervalMs() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationConfig
getResourceMetadata() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
getResourceWatcherFetchCount() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesResourceMetadata
getRetryBackoffMs() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
getTopicSpecs() - Method in class io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig
GROUP_NAME - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
GROUP_NAME - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource

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
HTTP_CONNECTION_TIMEOUT_MS - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
HTTP_READ_TIMEOUT_MS - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource

I

ICallbackResponse - Interface in io.confluent.security.audit.telemetry.exporter.config.remote.polling
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
incrementResourceWatcherFetchCount() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesResourceMetadata
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
io.confluent.security.audit.telemetry.exporter.config.remote - package io.confluent.security.audit.telemetry.exporter.config.remote
io.confluent.security.audit.telemetry.exporter.config.remote.polling - package io.confluent.security.audit.telemetry.exporter.config.remote.polling
io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes - package io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes
isEnabled() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.RemoteConfigConfiguration
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_FETCH_CONSUMER - Enum constant in enum class io.confluent.security.audit.router.AuditLogRouterUtils.RequestNameOverrides
KAFKA_FETCH_FOLLOWER - Enum constant in enum class io.confluent.security.audit.router.AuditLogRouterUtils.RequestNameOverrides
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
KubernetesConfigMapRemoteConfigurationConfig - Class in io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes
KubernetesConfigMapRemoteConfigurationConfig(Map<?, ?>, boolean) - Constructor for class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
KubernetesConfigMapRemoteConfigurationSource<T> - Class in io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes: This RemoteConfigurationSource will continuously poll the Kubernetes API for a ConfigMap containing the RemoteConfiguration object.
KubernetesConfigMapRemoteConfigurationSource(KubernetesConfigMapRemoteConfigurationConfig, Optional<String>, Consumer<T>, Class<T>) - Constructor for class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
KubernetesResourceMetadata - Class in io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes
KubernetesResourceMetadata() - Constructor for class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesResourceMetadata
KubernetesResourceMetadata(String, String) - Constructor for class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesResourceMetadata

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
MAX_RETRY_BACKOFF_MS - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
MAX_RETRY_BACKOFF_MS_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
maybeFetchIdentityInfo(KafkaPrincipal, Function<IdentityMetadata, Optional<T>>) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
maybeGetIdentityCRN(KafkaPrincipal, String) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
MDS_AUTHORIZE - Enum constant in enum class io.confluent.security.audit.router.AuditLogRouterUtils.RequestNameOverrides
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
METRIC_NAME - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
metrics() - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
multiplePrincipal(KafkaPrincipal) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils

N

name - Variable in enum class 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.crn.ConfluentServerCrnAuthority
name() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec
NAMESPACE_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
NAMESPACE_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
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
onCallbackFailure(Exception) - Method in interface io.confluent.security.audit.telemetry.exporter.config.remote.polling.ICallbackResponse
onCallbackFailure(Exception) - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
onCallbackSuccess() - Method in interface io.confluent.security.audit.telemetry.exporter.config.remote.polling.ICallbackResponse
onCallbackSuccess() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
onReceiveCallback(RemoteAuditConfiguration) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
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
PollingRemoteConfigurationConfig - Class in io.confluent.security.audit.telemetry.exporter.config.remote.polling
PollingRemoteConfigurationConfig(ConfigDef, Map<?, ?>, boolean) - Constructor for class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationConfig: Constructor for child classes
PollingRemoteConfigurationSource<T> - Class in io.confluent.security.audit.telemetry.exporter.config.remote.polling: This PollingRemoteConfigurationSource class provides a generic polling implementation for remote configuration sources.
PollingRemoteConfigurationSource(long, Consumer<T>, Class<T>) - Constructor for class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationSource
prefix - Variable in enum class 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.AuditLogRateLimiter
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.AuditLogRateLimiter
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
recordWatcherMetric(String, String, int) - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
REFRESH_INTERVAL_SEC_CONFIG - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationConfig
REFRESH_INTERVAL_SEC_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationConfig
REMOTE_AUDIT_LOG_RECONFIGURE_FAILURE_COUNT - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
REMOTE_AUDIT_LOG_REGION_COUNT - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
REMOTE_AUDIT_LOG_SOURCE_FAILURE_COUNT - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
REMOTE_AUDIT_LOG_SOURCE_START_FAILURE_COUNT - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
REMOTE_AUDIT_LOG_SOURCE_SUCCESS_COUNT - Static variable in class io.confluent.security.audit.provider.ConfluentAuditLogProvider.AuditLogMetrics
RemoteConfigConfiguration - Class in io.confluent.security.audit.telemetry.exporter.config.remote
RemoteConfigConfiguration(ConfigDef, Map<?, ?>, boolean) - Constructor for class io.confluent.security.audit.telemetry.exporter.config.remote.RemoteConfigConfiguration
RemoteConfigurationSource<T> - Interface in io.confluent.security.audit.telemetry.exporter.config.remote
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
RETRY_BACKOFF_MS - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
RETRY_BACKOFF_MS_DOC - Static variable in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationConfig
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
setConfigurationChangeCallback(Consumer<T>) - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationSource: Only one callback can be registered.
setConfigurationChangeCallback(Consumer<T>) - Method in interface io.confluent.security.audit.telemetry.exporter.config.remote.RemoteConfigurationSource: Registers a callback to be called when the remote configuration has changed
setCurrentResourceVersion(String) - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesResourceMetadata
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, AuthenticationException, CrnAuthority) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
setIdentityInformation(AuthenticationInfo.Builder, KafkaPrincipal, KafkaPrincipal, CrnAuthority) - Static method in class io.confluent.security.audit.AuditLogOAuthUtils
setLatestResourceVersion(String) - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesResourceMetadata
setMetrics(Metrics) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
setMetrics(Metrics) - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource
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
setResourceWatcherFetchCount(int) - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesResourceMetadata
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(List<TopicSpec>) - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Topics
setTopics(Map<String, TopicSpec>) - Method in class io.confluent.security.audit.telemetry.exporter.TopicManager.Builder
start() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationSource
start() - Method in interface io.confluent.security.audit.telemetry.exporter.config.remote.RemoteConfigurationSource
start(Map<String, ?>) - Method in class io.confluent.security.audit.provider.ConfluentAuditLogProvider
stop() - Method in class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationSource
stop() - Method in interface io.confluent.security.audit.telemetry.exporter.config.remote.RemoteConfigurationSource
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 - Variable in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Topics
topics() - Method in class io.confluent.security.audit.telemetry.exporter.TopicSpec.Topics
Topics() - Constructor for 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.AuditLogRateLimiter
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 class io.confluent.security.audit.router.AuditLogRouterResult: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.security.audit.router.AuditLogRouterUtils.RequestNameOverrides: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.confluent.security.audit.router.AuditLogRouterResult: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.security.audit.router.AuditLogRouterUtils.RequestNameOverrides: Returns an array containing the constants of this enum class, 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
All Classes and Interfaces|All Packages|Constant Field Values