public class UserTenantPrincipalBuilder extends Object implements org.apache.kafka.common.security.auth.KafkaPrincipalBuilder, org.apache.kafka.common.security.auth.KafkaPrincipalSerde
Constructor and Description |
---|
UserTenantPrincipalBuilder() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.security.auth.KafkaPrincipal |
build(org.apache.kafka.common.security.auth.AuthenticationContext authenticationContext) |
org.apache.kafka.common.security.auth.KafkaPrincipal |
deserialize(byte[] bytes) |
byte[] |
serialize(org.apache.kafka.common.security.auth.KafkaPrincipal principal) |
public org.apache.kafka.common.security.auth.KafkaPrincipal build(org.apache.kafka.common.security.auth.AuthenticationContext authenticationContext)
build
in interface org.apache.kafka.common.security.auth.KafkaPrincipalBuilder
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