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

  • Field Details

  • Constructor Details

    • ConfluentAuditLogProvider

      public ConfluentAuditLogProvider()

  • Method Details

    • 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

    • onReceiveCallback

      public void onReceiveCallback(io.confluent.auditlog.remote.RemoteAuditConfiguration newRemoteConfiguration)

    • configureRemoteConfig

      public RemoteConfigurationSource<io.confluent.auditlog.remote.RemoteAuditConfiguration> configureRemoteConfig(Map<String,?> configs)

    • 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()

    • getAuditLogConfig

      public AuditLogConfig getAuditLogConfig()

    • getAuditLogRouterJsonConfig

      public AuditLogRouterJsonConfig getAuditLogRouterJsonConfig()

    • isEventLoggerReady

      public boolean isEventLoggerReady()

    • metrics

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