public class ConfluentAuditLogProvider extends Object implements org.apache.kafka.server.audit.AuditLogProvider, org.apache.kafka.common.ClusterResourceListener
Modifier and Type | Class and Description |
---|---|
class |
ConfluentAuditLogProvider.AuditLogMetrics |
Modifier and Type | Field and Description |
---|---|
static String |
AUTHENTICATION_MESSAGE_TYPE |
static String |
AUTHORIZATION_MESSAGE_TYPE |
static String |
KAFKA_REQUEST_MESSAGE_TYPE |
Constructor and Description |
---|
ConfluentAuditLogProvider() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
close(String brokerSessionUuid) |
void |
configure(Map<String,?> configs)
The provider is configured and started during
start(Map) to get access to the
interbroker properties. |
io.confluent.telemetry.events.EventLogger |
getEventLogger() |
ExecutorService |
initExecutor() |
boolean |
isEventLoggerReady() |
void |
logEvent(org.apache.kafka.server.audit.AuditEvent auditEvent) |
void |
logEvent(org.apache.kafka.server.audit.AuditEvent auditEvent,
boolean isProxyModeLocal) |
org.apache.kafka.common.metrics.Metrics |
metrics() |
void |
onUpdate(org.apache.kafka.common.ClusterResource clusterResource) |
boolean |
providerConfigured(Map<String,?> configs) |
Set<String> |
reconfigurableConfigs() |
void |
reconfigure(Map<String,?> configs) |
void |
setMetrics(org.apache.kafka.common.metrics.Metrics metrics) |
void |
setSanitizer(UnaryOperator<org.apache.kafka.server.audit.AuditEvent> sanitizer) |
CompletionStage<Void> |
start(Map<String,?> interBrokerListenerConfigs) |
boolean |
usesMetadataFromThisKafkaCluster() |
void |
validateReconfiguration(Map<String,?> configs) |
public static final String AUTHORIZATION_MESSAGE_TYPE
public static final String AUTHENTICATION_MESSAGE_TYPE
public static final String KAFKA_REQUEST_MESSAGE_TYPE
public void onUpdate(org.apache.kafka.common.ClusterResource clusterResource)
onUpdate
in interface org.apache.kafka.common.ClusterResourceListener
public void configure(Map<String,?> configs)
start(Map)
to get access to the
interbroker properties.configure
in interface org.apache.kafka.common.Configurable
public Set<String> reconfigurableConfigs()
reconfigurableConfigs
in interface org.apache.kafka.common.Reconfigurable
public void validateReconfiguration(Map<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(Map<String,?> configs)
reconfigure
in interface org.apache.kafka.common.Reconfigurable
public CompletionStage<Void> start(Map<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 void logEvent(org.apache.kafka.server.audit.AuditEvent auditEvent, boolean isProxyModeLocal)
logEvent
in interface org.apache.kafka.server.audit.AuditLogProvider
public boolean usesMetadataFromThisKafkaCluster()
usesMetadataFromThisKafkaCluster
in interface org.apache.kafka.server.audit.AuditLogProvider
public boolean providerConfigured(Map<String,?> configs)
providerConfigured
in interface org.apache.kafka.server.audit.AuditLogProvider
public void setSanitizer(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(String brokerSessionUuid) throws Exception
close
in interface org.apache.kafka.server.audit.AuditLogProvider
Exception
public void close()
close
in interface AutoCloseable
public ExecutorService initExecutor()
public io.confluent.telemetry.events.EventLogger getEventLogger()
public boolean isEventLoggerReady()
public org.apache.kafka.common.metrics.Metrics metrics()