SslPrincipalMapper sslPrincipalMapper
SslChannelBuilder
SslChannelBuilder
is a ChannelBuilder for Kafka clients and brokers when security.protocol configuration property is SSL
.
SslChannelBuilder
is a ListenerReconfigurable
.
SslChannelBuilder
is created when ChannelBuilders
utility is used to create a ChannelBuilder for SSL security protocol.
Creating SslChannelBuilder Instance
SslChannelBuilder
takes the following to be created:
SslChannelBuilder
initializes the internal properties.
SslChannelBuilder and SslPrincipalMapper
sslPrincipalMapper
is a SslPrincipalMapper that is used to create a SslAuthenticator when SslChannelBuilder
is requested to build a channel.
sslPrincipalMapper
is created based on SSL principal mapping rules when SslChannelBuilder
is requested to configure with ssl.principal.mapping.rules configuration property defined.
Creating KafkaChannel — buildChannel
Method
KafkaChannel buildChannel(
String id,
SelectionKey key,
int maxReceiveSize,
MemoryPool memoryPool)
Note
|
buildChannel is part of the ChannelBuilder contract to build a KafkaChannel .
|
buildChannel
…FIXME
configure
Method
void configure(
Map<String, ?> configs)
Note
|
configure is part of the Configurable contract to pass configurations.
|
configure
initializes the sslPrincipalMapper internal registry (using SslPrincipalMapper utility) if ssl.principal.mapping.rules configuration property is defined.
configure
creates a SslFactory (for the mode and the isInterBrokerListener flag) and requests it to configure (with the given configs
).
buildTransportLayer
Method
SslTransportLayer buildTransportLayer(
SslFactory sslFactory,
String id,
SelectionKey key,
String host)
buildTransportLayer
…FIXME
Note
|
buildTransportLayer is used when SslChannelBuilder is requested to buildChannel.
|