Interface KafkaPrincipalBuilder

All Superinterfaces:

KafkaPrincipalSerde

public interface KafkaPrincipalBuilder
extends KafkaPrincipalSerde

Pluggable principal builder interface which supports both SSL authentication through SslAuthenticationContext and SASL through SaslAuthenticationContext. Note that the Configurable and Closeable interfaces are respected if implemented. Additionally, implementations must provide a default no-arg constructor.

Method Summary

Modifier and Type	Method	Description
KafkaPrincipal	build(AuthenticationContext context)	Build a kafka principal from the authentication context.

Methods inherited from interface org.apache.kafka.common.security.auth.KafkaPrincipalSerde

deserialize, serialize

Method Details

build

KafkaPrincipal build(AuthenticationContext context)

Build a kafka principal from the authentication context.

Parameters:

context - The authentication context (either SslAuthenticationContext or SaslAuthenticationContext)

Returns:

The built principal which may provide additional enrichment through a subclass of KafkaPrincipalBuilder.