public class ConfluentAuditLogProvider
extends java.lang.Object
implements org.apache.kafka.server.audit.AuditLogProvider, org.apache.kafka.common.ClusterResourceListener
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
AUTHENTICATION_MESSAGE_TYPE |
static java.lang.String |
AUTHORIZATION_MESSAGE_TYPE |
protected io.confluent.telemetry.events.serde.Serializer<AuditLogEntry> |
cloudEventSerializer |
protected org.slf4j.Logger |
fallbackLog |
protected static org.slf4j.Logger |
log |
Constructor and Description |
---|
ConfluentAuditLogProvider() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs)
The provider is configured and started during
start(Map) to get access to the
interbroker properties. |
io.confluent.telemetry.events.EventLogger<AuditLogEntry> |
getEventLogger() |
java.util.concurrent.ExecutorService |
initExecutor() |
boolean |
isEventLoggerReady() |
void |
logEvent(org.apache.kafka.server.audit.AuditEvent auditEvent) |
protected org.apache.kafka.common.metrics.Metrics |
metrics() |
protected org.apache.kafka.common.utils.Time |
metricsTime() |
void |
onUpdate(org.apache.kafka.common.ClusterResource clusterResource) |
boolean |
providerConfigured(java.util.Map<java.lang.String,?> configs) |
java.util.Set<java.lang.String> |
reconfigurableConfigs() |
void |
reconfigure(java.util.Map<java.lang.String,?> configs) |
void |
setMetrics(org.apache.kafka.common.metrics.Metrics metrics) |
void |
setSanitizer(java.util.function.UnaryOperator<org.apache.kafka.server.audit.AuditEvent> sanitizer) |
protected void |
setupMetrics(org.apache.kafka.common.utils.Time time) |
java.util.concurrent.CompletionStage<java.lang.Void> |
start(java.util.Map<java.lang.String,?> interBrokerListenerConfigs) |
boolean |
usesMetadataFromThisKafkaCluster() |
void |
validateReconfiguration(java.util.Map<java.lang.String,?> configs) |
public static final java.lang.String AUTHORIZATION_MESSAGE_TYPE
public static final java.lang.String AUTHENTICATION_MESSAGE_TYPE
protected static final org.slf4j.Logger log
protected final io.confluent.telemetry.events.serde.Serializer<AuditLogEntry> cloudEventSerializer
protected final org.slf4j.Logger fallbackLog
public void onUpdate(org.apache.kafka.common.ClusterResource clusterResource)
onUpdate
in interface org.apache.kafka.common.ClusterResourceListener
public void configure(java.util.Map<java.lang.String,?> configs)
start(Map)
to get access to the
interbroker properties.configure
in interface org.apache.kafka.common.Configurable
public java.util.Set<java.lang.String> reconfigurableConfigs()
reconfigurableConfigs
in interface org.apache.kafka.common.Reconfigurable
public void validateReconfiguration(java.util.Map<java.lang.String,?> configs) throws org.apache.kafka.common.config.ConfigException
validateReconfiguration
in interface org.apache.kafka.common.Reconfigurable
org.apache.kafka.common.config.ConfigException
public void reconfigure(java.util.Map<java.lang.String,?> configs)
reconfigure
in interface org.apache.kafka.common.Reconfigurable
public java.util.concurrent.CompletionStage<java.lang.Void> start(java.util.Map<java.lang.String,?> interBrokerListenerConfigs)
start
in interface org.apache.kafka.server.audit.AuditLogProvider
public void logEvent(org.apache.kafka.server.audit.AuditEvent auditEvent)
logEvent
in interface org.apache.kafka.server.audit.AuditLogProvider
public boolean usesMetadataFromThisKafkaCluster()
usesMetadataFromThisKafkaCluster
in interface org.apache.kafka.server.audit.AuditLogProvider
public boolean providerConfigured(java.util.Map<java.lang.String,?> configs)
providerConfigured
in interface org.apache.kafka.server.audit.AuditLogProvider
public void setSanitizer(java.util.function.UnaryOperator<org.apache.kafka.server.audit.AuditEvent> sanitizer)
setSanitizer
in interface org.apache.kafka.server.audit.AuditLogProvider
public void setMetrics(org.apache.kafka.common.metrics.Metrics metrics)
setMetrics
in interface org.apache.kafka.server.audit.AuditLogProvider
public void close()
close
in interface java.lang.AutoCloseable
public java.util.concurrent.ExecutorService initExecutor()
public io.confluent.telemetry.events.EventLogger<AuditLogEntry> getEventLogger()
public boolean isEventLoggerReady()
protected org.apache.kafka.common.metrics.Metrics metrics()
protected void setupMetrics(org.apache.kafka.common.utils.Time time)
protected org.apache.kafka.common.utils.Time metricsTime()