public class MultiTenantPrincipal
extends org.apache.kafka.common.security.auth.ConfluentPrincipal
Modifier and Type | Field and Description |
---|---|
static String |
DELIMITER |
static String |
TENANT_USER_TYPE |
static String |
TENANT_USERV2_TYPE |
static String |
TENANT_WILDCARD_USER_TYPE |
static String |
TENANT_WILDCARD_USERV2_TYPE |
static String |
USERV2 |
static org.apache.kafka.common.security.auth.KafkaPrincipal |
WILDCARD_USERV2_PRINCIPAL |
Constructor and Description |
---|
MultiTenantPrincipal(String user,
String saslAuthenticationId,
TenantMetadata tenantMetadata) |
MultiTenantPrincipal(String user,
String saslAuthenticationId,
TenantMetadata tenantMetadata,
IdentityMetadata identityMetadata) |
MultiTenantPrincipal(String user,
TenantMetadata tenantMetadata) |
MultiTenantPrincipal(String user,
TenantMetadata tenantMetadata,
IdentityMetadata identityMetadata) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
boolean |
isInternalUser() |
boolean |
isSuperUser(boolean enableDataplaneRbacForPKC,
boolean oauthSuperUserDisable) |
static boolean |
isTenantPrincipal(org.apache.kafka.common.security.auth.KafkaPrincipal principal) |
Optional<IdentityMetadata> |
maybeGetIdentityMetadata() |
TenantMetadata |
tenantMetadata() |
String |
toString() |
String |
user() |
authenticationId
getName, getPrincipalType, tokenAuthenticated, tokenAuthenticated
public static final String TENANT_USER_TYPE
public static final String TENANT_WILDCARD_USER_TYPE
public static final String DELIMITER
public static final String USERV2
public static final org.apache.kafka.common.security.auth.KafkaPrincipal WILDCARD_USERV2_PRINCIPAL
public static final String TENANT_USERV2_TYPE
public static final String TENANT_WILDCARD_USERV2_TYPE
public MultiTenantPrincipal(String user, TenantMetadata tenantMetadata)
public MultiTenantPrincipal(String user, String saslAuthenticationId, TenantMetadata tenantMetadata)
public MultiTenantPrincipal(String user, TenantMetadata tenantMetadata, IdentityMetadata identityMetadata)
public MultiTenantPrincipal(String user, String saslAuthenticationId, TenantMetadata tenantMetadata, IdentityMetadata identityMetadata)
public TenantMetadata tenantMetadata()
public String user()
public Optional<IdentityMetadata> maybeGetIdentityMetadata()
public boolean isSuperUser(boolean enableDataplaneRbacForPKC, boolean oauthSuperUserDisable)
public boolean isInternalUser()
public boolean equals(Object o)
public int hashCode()
public String toString()
public static boolean isTenantPrincipal(org.apache.kafka.common.security.auth.KafkaPrincipal principal)