Class ConfluentAuthenticationEvent
java.lang.Object
io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
- All Implemented Interfaces:
org.apache.kafka.server.audit.AuditEvent,org.apache.kafka.server.audit.AuthenticationEvent
public class ConfluentAuthenticationEvent
extends Object
implements org.apache.kafka.server.audit.AuthenticationEvent
-
Constructor Summary
ConstructorsConstructorDescriptionConfluentAuthenticationEvent(org.apache.kafka.server.audit.AuthenticationEvent authenticationEvent, io.confluent.security.authorizer.Scope scope) -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.kafka.common.security.auth.AuthenticationContextOptional<org.apache.kafka.common.errors.AuthenticationException> data()booleanio.confluent.security.authorizer.ScopegetScope()inthashCode()Optional<org.apache.kafka.common.security.auth.KafkaPrincipal> voidorg.apache.kafka.server.audit.AuditEventStatusstatus()toString()org.apache.kafka.server.audit.AuditEventTypetype()uuid()
-
Constructor Details
-
ConfluentAuthenticationEvent
public ConfluentAuthenticationEvent(org.apache.kafka.server.audit.AuthenticationEvent authenticationEvent, io.confluent.security.authorizer.Scope scope)
-
-
Method Details
-
principal
- Specified by:
principalin interfaceorg.apache.kafka.server.audit.AuthenticationEvent
-
authenticationContext
public org.apache.kafka.common.security.auth.AuthenticationContext authenticationContext()- Specified by:
authenticationContextin interfaceorg.apache.kafka.server.audit.AuthenticationEvent
-
authenticationException
- Specified by:
authenticationExceptionin interfaceorg.apache.kafka.server.audit.AuthenticationEvent
-
uuid
- Specified by:
uuidin interfaceorg.apache.kafka.server.audit.AuditEvent
-
timestamp
- Specified by:
timestampin interfaceorg.apache.kafka.server.audit.AuditEvent
-
type
public org.apache.kafka.server.audit.AuditEventType type()- Specified by:
typein interfaceorg.apache.kafka.server.audit.AuditEvent
-
status
public org.apache.kafka.server.audit.AuditEventStatus status()- Specified by:
statusin interfaceorg.apache.kafka.server.audit.AuditEvent
-
data
-
setData
-
getScope
public io.confluent.security.authorizer.Scope getScope() -
equals
-
hashCode
-
toString
-