public class ConfluentAuditLogProvider
extends java.lang.Object
implements io.confluent.security.authorizer.provider.AuditLogProvider, org.apache.kafka.common.ClusterResourceListener
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
AUTHORIZATION_MESSAGE_TYPE |
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.. |
EventLogger |
getEventLogger() |
io.confluent.security.authorizer.Scope |
getScope() |
java.util.concurrent.ExecutorService |
initExecutor() |
boolean |
isEventLoggerReady() |
void |
logAuthorization(io.confluent.security.authorizer.RequestContext requestContext,
io.confluent.security.authorizer.Action action,
io.confluent.security.authorizer.AuthorizeResult authorizeResult,
io.confluent.security.authorizer.AuthorizePolicy authorizePolicy) |
void |
onUpdate(org.apache.kafka.common.ClusterResource clusterResource) |
boolean |
providerConfigured(java.util.Map<java.lang.String,?> configs) |
java.lang.String |
providerName() |
java.util.Set<java.lang.String> |
reconfigurableConfigs() |
void |
reconfigure(java.util.Map<java.lang.String,?> configs) |
java.util.concurrent.CompletionStage<java.lang.Void> |
start(org.apache.kafka.server.authorizer.AuthorizerServerInfo serverInfo,
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
protected static final org.slf4j.Logger log
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(org.apache.kafka.server.authorizer.AuthorizerServerInfo serverInfo, java.util.Map<java.lang.String,?> interBrokerListenerConfigs)
start
in interface io.confluent.security.authorizer.provider.Provider
public java.lang.String providerName()
providerName
in interface io.confluent.security.authorizer.provider.Provider
public boolean usesMetadataFromThisKafkaCluster()
usesMetadataFromThisKafkaCluster
in interface io.confluent.security.authorizer.provider.Provider
public boolean providerConfigured(java.util.Map<java.lang.String,?> configs)
providerConfigured
in interface io.confluent.security.authorizer.provider.AuditLogProvider
public void logAuthorization(io.confluent.security.authorizer.RequestContext requestContext, io.confluent.security.authorizer.Action action, io.confluent.security.authorizer.AuthorizeResult authorizeResult, io.confluent.security.authorizer.AuthorizePolicy authorizePolicy)
logAuthorization
in interface io.confluent.security.authorizer.provider.AuditLogProvider
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
public java.util.concurrent.ExecutorService initExecutor()
public EventLogger getEventLogger()
public io.confluent.security.authorizer.Scope getScope()
public boolean isEventLoggerReady()