KafkaPrincipalBuilder is the abstraction of principal builders that can build a KafkaPrincipal for authentication.

Configurable and java.io.Closeable interfaces are respected if implemented.

KafkaPrincipalBuilder is configured by the principal.builder.class configuration property.

Table 1. KafkaPrincipalBuilder Contract
Method Description


KafkaPrincipal build(
  AuthenticationContext context)

Builds a KafkaPrincipal for the AuthenticationContext

Used when:

  • PlaintextAuthenticator is requested for a principal

  • SaslServerAuthenticator is requested for a principal

  • SslAuthenticator is requested for a principal

DefaultKafkaPrincipalBuilder is the default and only known KafkaPrincipalBuilder in Apache Kafka.

results matching ""

    No results matching ""