Class FetchRequestAuditExtractor

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

public class FetchRequestAuditExtractor extends Object
  • Constructor Details

    • FetchRequestAuditExtractor

      public FetchRequestAuditExtractor()
  • Method Details

    • extract

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