io.confluent.security.audit.provider

Class ConfluentAuditLogProvider

java.lang.Object

io.confluent.security.audit.provider.ConfluentAuditLogProvider

All Implemented Interfaces:

AutoCloseable, org.apache.kafka.common.ClusterResourceListener, org.apache.kafka.common.Configurable, org.apache.kafka.common.Reconfigurable, org.apache.kafka.server.audit.AuditLogProvider

public class ConfluentAuditLogProvider
extends Object
implements org.apache.kafka.server.audit.AuditLogProvider, org.apache.kafka.common.ClusterResourceListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ConfluentAuditLogProvider.AuditLogMetrics

Field Summary

Fields

Modifier and Type	Field and Description
static String	AUTHENTICATION_MESSAGE_TYPE
static String	AUTHORIZATION_MESSAGE_TYPE
static String	KAFKA_REQUEST_MESSAGE_TYPE

Constructor Summary

Constructors

Constructor and Description
ConfluentAuditLogProvider()

Method Summary

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)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

AUTHORIZATION_MESSAGE_TYPE

public static final String AUTHORIZATION_MESSAGE_TYPE

See Also:

Constant Field Values

AUTHENTICATION_MESSAGE_TYPE

public static final String AUTHENTICATION_MESSAGE_TYPE

See Also:

Constant Field Values

KAFKA_REQUEST_MESSAGE_TYPE

public static final String KAFKA_REQUEST_MESSAGE_TYPE

See Also:

Constant Field Values

Constructor Detail

ConfluentAuditLogProvider

public ConfluentAuditLogProvider()

Method Detail

onUpdate

public void onUpdate(org.apache.kafka.common.ClusterResource clusterResource)

Specified by:

onUpdate in interface org.apache.kafka.common.ClusterResourceListener

configure

public void configure(Map<String,?> configs)

The provider is configured and started during start(Map) to get access to the interbroker properties.

Specified by:

configure in interface org.apache.kafka.common.Configurable

reconfigurableConfigs

public Set<String> reconfigurableConfigs()

Specified by:

reconfigurableConfigs in interface org.apache.kafka.common.Reconfigurable

validateReconfiguration

public void validateReconfiguration(Map<String,?> configs)
                             throws org.apache.kafka.common.config.ConfigException

Specified by:

validateReconfiguration in interface org.apache.kafka.common.Reconfigurable

Throws:

org.apache.kafka.common.config.ConfigException

reconfigure

public void reconfigure(Map<String,?> configs)

Specified by:

reconfigure in interface org.apache.kafka.common.Reconfigurable

start

public CompletionStage<Void> start(Map<String,?> interBrokerListenerConfigs)

Specified by:

start in interface org.apache.kafka.server.audit.AuditLogProvider

logEvent

public void logEvent(org.apache.kafka.server.audit.AuditEvent auditEvent)

Specified by:

logEvent in interface org.apache.kafka.server.audit.AuditLogProvider

logEvent

public void logEvent(org.apache.kafka.server.audit.AuditEvent auditEvent,
                     boolean isProxyModeLocal)

Specified by:

logEvent in interface org.apache.kafka.server.audit.AuditLogProvider

usesMetadataFromThisKafkaCluster

public boolean usesMetadataFromThisKafkaCluster()

Specified by:

usesMetadataFromThisKafkaCluster in interface org.apache.kafka.server.audit.AuditLogProvider

providerConfigured

public boolean providerConfigured(Map<String,?> configs)

Specified by:

providerConfigured in interface org.apache.kafka.server.audit.AuditLogProvider

setSanitizer

public void setSanitizer(UnaryOperator<org.apache.kafka.server.audit.AuditEvent> sanitizer)

Specified by:

setSanitizer in interface org.apache.kafka.server.audit.AuditLogProvider

setMetrics

public void setMetrics(org.apache.kafka.common.metrics.Metrics metrics)

Specified by:

setMetrics in interface org.apache.kafka.server.audit.AuditLogProvider

close

public void close(String brokerSessionUuid)
           throws Exception

Specified by:

close in interface org.apache.kafka.server.audit.AuditLogProvider

Throws:

Exception

close

public void close()

Specified by:

close in interface AutoCloseable

initExecutor

public ExecutorService initExecutor()

getEventLogger

public io.confluent.telemetry.events.EventLogger getEventLogger()

isEventLoggerReady

public boolean isEventLoggerReady()

metrics

public org.apache.kafka.common.metrics.Metrics metrics()