Package io.confluent.security.audit

Class AuditLogOAuthUtils

java.lang.Object
io.confluent.security.audit.AuditLogOAuthUtils
public class AuditLogOAuthUtils extends Object

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    IDENTITY_POOL_ID_KEY
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    AuditLogOAuthUtils()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static Optional<String>
    externalIdentityId(org.apache.kafka.common.security.auth.KafkaPrincipal principal)
     
    static <T> Optional<T>
    maybeFetchIdentityInfo(org.apache.kafka.common.security.auth.KafkaPrincipal kafkaPrincipal, Function<org.apache.kafka.common.security.auth.IdentityMetadata,Optional<T>> 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)
     

    Methods inherited from class java.lang.Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

  • Constructor Details

    • AuditLogOAuthUtils

      public AuditLogOAuthUtils()

  • Method Details

    • setIdentityInformation

      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)

    • maybeFetchIdentityInfo

      public static <T> Optional<T> maybeFetchIdentityInfo(org.apache.kafka.common.security.auth.KafkaPrincipal kafkaPrincipal, Function<org.apache.kafka.common.security.auth.IdentityMetadata,Optional<T>> supplier)

    • setIdentityField

      public static void setIdentityField(io.confluent.security.audit.AuthenticationInfo.Builder authenticationBuilder, org.apache.kafka.common.security.auth.KafkaPrincipal principal, String crnName)

    • externalIdentityId

      public static Optional<String> externalIdentityId(org.apache.kafka.common.security.auth.KafkaPrincipal principal)

    • maybeGetIdentityCRN

      public static Optional<io.confluent.crn.ConfluentResourceName> maybeGetIdentityCRN(org.apache.kafka.common.security.auth.KafkaPrincipal principal, String authName)

    • setIdentityInformation

      public static void setIdentityInformation(io.confluent.security.audit.AuthenticationInfo.Builder authenticationBuilder, org.apache.kafka.common.errors.AuthenticationException authenticationException, io.confluent.crn.CrnAuthority crnAuthority)

    • setAssignedPrincipal

      public static void setAssignedPrincipal(io.confluent.security.audit.AuthorizationInfo.Builder authorizationBuilder, org.apache.kafka.common.security.auth.KafkaPrincipal principal)

    • multiplePrincipal

      public static boolean multiplePrincipal(org.apache.kafka.common.security.auth.KafkaPrincipal principal)