Package io.confluent.security.audit.kafka

Class ProduceRequestAuditExtractor

java.lang.Object

io.confluent.security.audit.kafka.ProduceRequestAuditExtractor

public class ProduceRequestAuditExtractor
extends Object

Constructor Summary

Constructors

Constructor	Description
ProduceRequestAuditExtractor()

Method Summary

Modifier and Type	Method	Description
static List<io.confluent.protobuf.events.auditlog.v2.AuditLog>	extract(org.apache.kafka.server.audit.KafkaRequestEvent requestEvent, AuditExtractorOptions extractorOptions)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ProduceRequestAuditExtractor

public ProduceRequestAuditExtractor()

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