public interface KafkaPrincipalBuilder

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. Note that custom implementations of KafkaPrincipalBuilder must also implement KafkaPrincipalSerde, otherwise brokers will not be able to forward requests to the controller.

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

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.

Interface KafkaPrincipalBuilder

Method Summary

Method Details

build