Class KafkaRequestToAuditEntry

java.lang.Object
io.confluent.security.audit.kafka.KafkaRequestToAuditEntry

public final class KafkaRequestToAuditEntry extends Object
  • Constructor Details

    • KafkaRequestToAuditEntry

      public KafkaRequestToAuditEntry()
  • Method Details

    • extractAuditLog

      public static List<io.confluent.protobuf.events.auditlog.v2.AuditLog> extractAuditLog(org.apache.kafka.server.audit.KafkaRequestEvent requestEvent, AuditExtractorOptions extractorOptions) throws Exception
      Throws:
      Exception