public class ConfluentAuthenticationEvent extends Object implements org.apache.kafka.server.audit.AuthenticationEvent
Constructor and Description |
---|
ConfluentAuthenticationEvent(org.apache.kafka.server.audit.AuthenticationEvent authenticationEvent,
io.confluent.security.authorizer.Scope scope) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.security.auth.AuthenticationContext |
authenticationContext() |
Optional<org.apache.kafka.common.errors.AuthenticationException> |
authenticationException() |
Map<String,Object> |
data() |
boolean |
equals(Object o) |
io.confluent.security.authorizer.Scope |
getScope() |
int |
hashCode() |
Optional<org.apache.kafka.common.security.auth.KafkaPrincipal> |
principal() |
org.apache.kafka.server.audit.AuditEventStatus |
status() |
Instant |
timestamp() |
String |
toString() |
org.apache.kafka.server.audit.AuditEventType |
type() |
UUID |
uuid() |
public ConfluentAuthenticationEvent(org.apache.kafka.server.audit.AuthenticationEvent authenticationEvent, io.confluent.security.authorizer.Scope scope)
public Optional<org.apache.kafka.common.security.auth.KafkaPrincipal> principal()
principal
in interface org.apache.kafka.server.audit.AuthenticationEvent
public org.apache.kafka.common.security.auth.AuthenticationContext authenticationContext()
authenticationContext
in interface org.apache.kafka.server.audit.AuthenticationEvent
public Optional<org.apache.kafka.common.errors.AuthenticationException> authenticationException()
authenticationException
in interface org.apache.kafka.server.audit.AuthenticationEvent
public UUID uuid()
uuid
in interface org.apache.kafka.server.audit.AuditEvent
public Instant timestamp()
timestamp
in interface org.apache.kafka.server.audit.AuditEvent
public org.apache.kafka.server.audit.AuditEventType type()
type
in interface org.apache.kafka.server.audit.AuditEvent
public org.apache.kafka.server.audit.AuditEventStatus status()
status
in interface org.apache.kafka.server.audit.AuditEvent
public Map<String,Object> data()
data
in interface org.apache.kafka.server.audit.AuditEvent
public io.confluent.security.authorizer.Scope getScope()