Class CreatePartitionsRequestAuditExtractor

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

public class CreatePartitionsRequestAuditExtractor extends Object
  • Constructor Details

    • CreatePartitionsRequestAuditExtractor

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