public class OAuthKafkaPrincipalBuilder extends Object implements org.apache.kafka.common.security.auth.KafkaPrincipalBuilder, org.apache.kafka.common.security.auth.KafkaPrincipalSerde, org.apache.kafka.common.Configurable
DefaultKafkaPrincipalBuilder
, which is used as a delegate.Constructor and Description |
---|
OAuthKafkaPrincipalBuilder() |
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) |
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 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