public class AuditLogOAuthUtils extends Object
Modifier and Type | Field and Description |
---|---|
static String |
IDENTITY_POOL_ID_KEY |
Constructor and Description |
---|
AuditLogOAuthUtils() |
Modifier and Type | Method and Description |
---|---|
static Optional<String> |
externalIdentityId(org.apache.kafka.common.security.auth.KafkaPrincipal principal) |
static Optional<String> |
maybeFetchIdentityInfo(org.apache.kafka.common.security.auth.KafkaPrincipal kafkaPrincipal,
Function<org.apache.kafka.common.security.auth.IdentityMetadata,Optional<String>> supplier) |
static Optional<io.confluent.crn.ConfluentResourceName> |
maybeGetIdentityCRN(org.apache.kafka.common.security.auth.KafkaPrincipal principal,
String authName) |
static boolean |
multiplePrincipal(org.apache.kafka.common.security.auth.KafkaPrincipal principal) |
static void |
setAssignedPrincipal(io.confluent.security.audit.AuthorizationInfo.Builder authorizationBuilder,
org.apache.kafka.common.security.auth.KafkaPrincipal principal) |
static void |
setIdentityField(io.confluent.security.audit.AuthenticationInfo.Builder authenticationBuilder,
org.apache.kafka.common.security.auth.KafkaPrincipal principal,
String crnName) |
static void |
setIdentityInformation(io.confluent.security.audit.AuthenticationInfo.Builder authenticationBuilder,
org.apache.kafka.common.errors.AuthenticationException authenticationException,
io.confluent.crn.CrnAuthority crnAuthority) |
static void |
setIdentityInformation(io.confluent.security.audit.AuthenticationInfo.Builder authenticationBuilder,
org.apache.kafka.common.security.auth.KafkaPrincipal eventPrincipal,
org.apache.kafka.common.security.auth.KafkaPrincipal originalPrincipal,
io.confluent.crn.CrnAuthority crnAuthority) |
public static final String IDENTITY_POOL_ID_KEY
public static void setIdentityInformation(io.confluent.security.audit.AuthenticationInfo.Builder authenticationBuilder, org.apache.kafka.common.security.auth.KafkaPrincipal eventPrincipal, org.apache.kafka.common.security.auth.KafkaPrincipal originalPrincipal, io.confluent.crn.CrnAuthority crnAuthority)
public static Optional<String> maybeFetchIdentityInfo(org.apache.kafka.common.security.auth.KafkaPrincipal kafkaPrincipal, Function<org.apache.kafka.common.security.auth.IdentityMetadata,Optional<String>> supplier)
public static void setIdentityField(io.confluent.security.audit.AuthenticationInfo.Builder authenticationBuilder, org.apache.kafka.common.security.auth.KafkaPrincipal principal, String crnName)
public static Optional<String> externalIdentityId(org.apache.kafka.common.security.auth.KafkaPrincipal principal)
public static Optional<io.confluent.crn.ConfluentResourceName> maybeGetIdentityCRN(org.apache.kafka.common.security.auth.KafkaPrincipal principal, String authName)
public static void setIdentityInformation(io.confluent.security.audit.AuthenticationInfo.Builder authenticationBuilder, org.apache.kafka.common.errors.AuthenticationException authenticationException, io.confluent.crn.CrnAuthority crnAuthority)
public static void setAssignedPrincipal(io.confluent.security.audit.AuthorizationInfo.Builder authorizationBuilder, org.apache.kafka.common.security.auth.KafkaPrincipal principal)
public static boolean multiplePrincipal(org.apache.kafka.common.security.auth.KafkaPrincipal principal)