SslAuthenticator
is an Authenticator for KafkaChannel when security.protocol configuration property is SSL
.
SslAuthenticator
is created (lazily as part of Supplier<Authenticator>
) when SslChannelBuilder
is requested to build a channel.
SslAuthenticator
is an internal class of SslChannelBuilder.
SslAuthenticator
takes the following to be created:
SslAuthenticator
initializes the KafkaPrincipalBuilder.
KafkaPrincipalBuilder principalBuilder
principalBuilder
is a KafkaPrincipalBuilder
.
principalBuilder
is created for SslAuthenticator
based on the given configuration properties, the SslTransportLayer and the SslPrincipalMapper.
KafkaPrincipal principal()
Note
|
principal is part of the Authenticator contract to…FIXME.
|
principal
…FIXME