public class MultiTenantPrincipalBuilder extends Object implements org.apache.kafka.common.security.auth.KafkaPrincipalBuilder, org.apache.kafka.common.security.auth.KafkaPrincipalSerde, org.apache.kafka.common.Configurable
MultiTenantPrincipal
if tenant
id is available. A regular KafkaPrincipal
without tenant
information is returned otherwise.Modifier and Type | Field and Description |
---|---|
static String |
CCLOUD_INTERNAL_USER |
Constructor and Description |
---|
MultiTenantPrincipalBuilder() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.security.auth.KafkaPrincipal |
build(org.apache.kafka.common.security.auth.AuthenticationContext context) |
void |
configure(Map<String,?> configs) |
org.apache.kafka.common.security.auth.KafkaPrincipal |
deserialize(byte[] bytes) |
byte[] |
serialize(org.apache.kafka.common.security.auth.KafkaPrincipal principal) |
String |
userResourceId(io.confluent.kafka.common.multitenant.oauth.OAuthBearerJwsToken token) |
public static final String CCLOUD_INTERNAL_USER
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public org.apache.kafka.common.security.auth.KafkaPrincipal build(org.apache.kafka.common.security.auth.AuthenticationContext context)
build
in interface org.apache.kafka.common.security.auth.KafkaPrincipalBuilder
public String userResourceId(io.confluent.kafka.common.multitenant.oauth.OAuthBearerJwsToken token)
public byte[] serialize(org.apache.kafka.common.security.auth.KafkaPrincipal principal) throws org.apache.kafka.common.errors.SerializationException
serialize
in interface org.apache.kafka.common.security.auth.KafkaPrincipalSerde
org.apache.kafka.common.errors.SerializationException
public org.apache.kafka.common.security.auth.KafkaPrincipal deserialize(byte[] bytes) throws org.apache.kafka.common.errors.SerializationException
deserialize
in interface org.apache.kafka.common.security.auth.KafkaPrincipalSerde
org.apache.kafka.common.errors.SerializationException