Package io.confluent.security.authorizer.provider

Class ConfluentAuthorizationEvent

java.lang.Object

io.confluent.security.authorizer.provider.ConfluentAuthorizationEvent

All Implemented Interfaces:

org.apache.kafka.server.audit.AuditEvent, org.apache.kafka.server.audit.AuthorizationEvent

public class ConfluentAuthorizationEvent
extends Object
implements org.apache.kafka.server.audit.AuthorizationEvent

The ConfluentAuthorizationEvent class is used to post confluent specific authorization audit events.

Constructor Summary

Constructors

Constructor	Description
ConfluentAuthorizationEvent(io.confluent.security.authorizer.Scope sourceScope, RequestContext requestContext, Action action, AuthorizeResult authorizationResult, AuthorizePolicy authorizePolicy)
ConfluentAuthorizationEvent(io.confluent.security.authorizer.Scope sourceScope, RequestContext requestContext, Action action, AuthorizeResult authorizationResult, AuthorizePolicy authorizePolicy, Instant timestamp)

Method Summary

Modifier and Type	Method	Description
Action	action()
org.apache.kafka.server.authorizer.AuthorizationResult	authorizationResult()
org.apache.kafka.server.authorizer.Action	authorizeAction()
AuthorizePolicy	authorizePolicy()
AuthorizeResult	authorizeResult()
Map<String,Object>	data()
boolean	equals(Object o)
int	hashCode()
RequestContext	requestContext()
void	setData(Map<String,Object> data)
io.confluent.security.authorizer.Scope	sourceScope()
org.apache.kafka.server.audit.AuditEventStatus	status()
Instant	timestamp()
String	toString()
org.apache.kafka.server.audit.AuditEventType	type()
UUID	uuid()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

ConfluentAuthorizationEvent

public ConfluentAuthorizationEvent(io.confluent.security.authorizer.Scope sourceScope,
 RequestContext requestContext,
 Action action,
 AuthorizeResult authorizationResult,
 AuthorizePolicy authorizePolicy,
 Instant timestamp)

ConfluentAuthorizationEvent

public ConfluentAuthorizationEvent(io.confluent.security.authorizer.Scope sourceScope,
 RequestContext requestContext,
 Action action,
 AuthorizeResult authorizationResult,
 AuthorizePolicy authorizePolicy)

Method Details

sourceScope

public io.confluent.security.authorizer.Scope sourceScope()

requestContext

public RequestContext requestContext()

Specified by:

requestContext in interface org.apache.kafka.server.audit.AuthorizationEvent

action

public Action action()

authorizeResult

public AuthorizeResult authorizeResult()

authorizePolicy

public AuthorizePolicy authorizePolicy()

uuid

public UUID uuid()

Specified by:

uuid in interface org.apache.kafka.server.audit.AuditEvent

timestamp

public Instant timestamp()

Specified by:

timestamp in interface org.apache.kafka.server.audit.AuditEvent

type

public org.apache.kafka.server.audit.AuditEventType type()

Specified by:

type in interface org.apache.kafka.server.audit.AuditEvent

status

public org.apache.kafka.server.audit.AuditEventStatus status()

Specified by:

status in interface org.apache.kafka.server.audit.AuditEvent

data

public Map<String,Object> data()

Specified by:

data in interface org.apache.kafka.server.audit.AuditEvent

setData

public void setData(Map<String,Object> data)

authorizeAction

public org.apache.kafka.server.authorizer.Action authorizeAction()

Specified by:

authorizeAction in interface org.apache.kafka.server.audit.AuthorizationEvent

authorizationResult

public org.apache.kafka.server.authorizer.AuthorizationResult authorizationResult()

Specified by:

authorizationResult in interface org.apache.kafka.server.audit.AuthorizationEvent

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object