public class AuditLogUtils extends Object
Modifier and Type | Field and Description |
---|---|
static String |
AUTHENTICATION_EVENT_NAME |
static String |
AUTHENTICATION_FAILED_EVENT_USER |
static String |
IDENTITY_POOL_ID_KEY |
Constructor and Description |
---|
AuditLogUtils() |
Modifier and Type | Method and Description |
---|---|
static AuditLog |
auditLog(org.apache.kafka.server.audit.KafkaRequestEvent requestEvent,
AuditExtractorOptions extractorOptions,
boolean hasAuthorizationFailure,
boolean validateOnly,
com.google.protobuf.Struct requestData,
Result.Status status,
com.google.protobuf.Struct resultData,
List<TypedCloudResourceRef> typedCloudResourceRefList,
String resourceCrn) |
static AuditLogEntry |
authenticationEvent(io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent authenticationEvent,
ConfluentServerCrnAuthority crnAuthority) |
static AuditLogEntry |
authenticationEvent(io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent authenticationEvent,
ConfluentServerCrnAuthority crnAuthority,
boolean omitClientAddress) |
static AuditLogEntry |
authorizationEvent(io.confluent.security.authorizer.provider.ConfluentAuthorizationEvent authorizationEvent,
ConfluentServerCrnAuthority crnAuthority) |
static AuditLogEntry |
authorizationEvent(io.confluent.security.authorizer.provider.ConfluentAuthorizationEvent authorizationEvent,
ConfluentServerCrnAuthority crnAuthority,
boolean omitClientAddress) |
static Optional<FullyQualifiedCloudResourceRef> |
cloudResourceRef(List<TypedCloudResourceRef> typedCloudResourceRefList) |
static boolean |
hasAuthorizationFailure(short errorCode) |
static String |
methodName(io.confluent.security.authorizer.provider.ConfluentAuthorizationEvent authorizationEvent) |
static String |
methodName(org.apache.kafka.server.audit.KafkaRequestEvent kafkaRequestEvent) |
static String |
requestCrn(ConfluentServerCrnAuthority crnAuthority,
org.apache.kafka.server.audit.KafkaRequestEvent requestEvent) |
static String |
requestResourceCrn(ConfluentServerCrnAuthority crnAuthority,
org.apache.kafka.server.audit.KafkaRequestEvent requestEvent,
io.confluent.security.authorizer.ResourcePattern resourcePattern) |
static io.confluent.crn.ConfluentResourceName.Element |
resourceNameElement(AuditLogEntry entry)
This returns the last element of the resource in the "resourceName" field.
|
static List<TypedCloudResourceRef> |
typedCloudResourceRefList(org.apache.kafka.server.audit.KafkaRequestEvent requestEvent) |
static RequestMetadata |
v2RequestMetadata(org.apache.kafka.server.audit.KafkaRequestEvent requestEvent,
AuditExtractorOptions extractorOptions) |
static Principal |
v2SchemaPrincipal(org.apache.kafka.server.audit.KafkaRequestEvent requestEvent) |
public static final String AUTHENTICATION_FAILED_EVENT_USER
public static final String AUTHENTICATION_EVENT_NAME
public static final String IDENTITY_POOL_ID_KEY
public static AuditLogEntry authorizationEvent(io.confluent.security.authorizer.provider.ConfluentAuthorizationEvent authorizationEvent, ConfluentServerCrnAuthority crnAuthority) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public static AuditLogEntry authorizationEvent(io.confluent.security.authorizer.provider.ConfluentAuthorizationEvent authorizationEvent, ConfluentServerCrnAuthority crnAuthority, boolean omitClientAddress) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public static String methodName(io.confluent.security.authorizer.provider.ConfluentAuthorizationEvent authorizationEvent)
public static io.confluent.crn.ConfluentResourceName.Element resourceNameElement(AuditLogEntry entry) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public static AuditLogEntry authenticationEvent(io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent authenticationEvent, ConfluentServerCrnAuthority crnAuthority) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public static AuditLogEntry authenticationEvent(io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent authenticationEvent, ConfluentServerCrnAuthority crnAuthority, boolean omitClientAddress) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public static AuditLog auditLog(org.apache.kafka.server.audit.KafkaRequestEvent requestEvent, AuditExtractorOptions extractorOptions, boolean hasAuthorizationFailure, boolean validateOnly, com.google.protobuf.Struct requestData, Result.Status status, com.google.protobuf.Struct resultData, List<TypedCloudResourceRef> typedCloudResourceRefList, String resourceCrn) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public static String requestCrn(ConfluentServerCrnAuthority crnAuthority, org.apache.kafka.server.audit.KafkaRequestEvent requestEvent) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public static String methodName(org.apache.kafka.server.audit.KafkaRequestEvent kafkaRequestEvent)
public static String requestResourceCrn(ConfluentServerCrnAuthority crnAuthority, org.apache.kafka.server.audit.KafkaRequestEvent requestEvent, io.confluent.security.authorizer.ResourcePattern resourcePattern) throws io.confluent.crn.CrnSyntaxException
io.confluent.crn.CrnSyntaxException
public static Principal v2SchemaPrincipal(org.apache.kafka.server.audit.KafkaRequestEvent requestEvent)
public static boolean hasAuthorizationFailure(short errorCode)
public static RequestMetadata v2RequestMetadata(org.apache.kafka.server.audit.KafkaRequestEvent requestEvent, AuditExtractorOptions extractorOptions)
public static Optional<FullyQualifiedCloudResourceRef> cloudResourceRef(List<TypedCloudResourceRef> typedCloudResourceRefList)
public static List<TypedCloudResourceRef> typedCloudResourceRefList(org.apache.kafka.server.audit.KafkaRequestEvent requestEvent)