public class DefaultAuditLogProvider
extends java.lang.Object
implements org.apache.kafka.server.audit.AuditLogProvider
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
log |
protected java.util.function.UnaryOperator<org.apache.kafka.server.audit.AuditEvent> |
sanitizer |
Constructor and Description |
---|
DefaultAuditLogProvider() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs) |
void |
logEvent(org.apache.kafka.server.audit.AuditEvent auditEvent) |
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 |
setSanitizer(java.util.function.UnaryOperator<org.apache.kafka.server.audit.AuditEvent> sanitizer) |
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) |
protected static final org.slf4j.Logger log
protected java.util.function.UnaryOperator<org.apache.kafka.server.audit.AuditEvent> sanitizer
public void configure(java.util.Map<java.lang.String,?> configs)
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 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 logEvent(org.apache.kafka.server.audit.AuditEvent auditEvent)
logEvent
in interface org.apache.kafka.server.audit.AuditLogProvider
public void close() throws java.io.IOException
close
in interface java.lang.AutoCloseable
java.io.IOException