SaslChannelBuilder

SaslChannelBuilder is a ChannelBuilder for SSL channels on Kafka clients and brokers.

SaslChannelBuilder is a ListenerReconfigurable.

SaslChannelBuilder is created when ChannelBuilders utility is used to create a ChannelBuilder for SASL_SSL or SASL_PLAINTEXT security protocols.

Creating SaslChannelBuilder Instance

SaslChannelBuilder takes the following to be created:

  • Mode (i.e. CLIENT or SERVER)

  • Lookup table of JaasContexts by name

  • SecurityProtocol

  • Listener name (only for SERVER channel builder)

  • isInterBrokerListener flag

  • clientSaslMechanism text

  • handshakeRequestEnable flag

  • CredentialCache

  • DelegationTokenCache

  • Time

SaslChannelBuilder initializes the internal properties.

configure Method

void configure(
  Map<String, ?> configs)
Note
 configure is part of the Configurable contract to pass configurations.

configure…​FIXME

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

buildTransportLayer Method

TransportLayer buildTransportLayer(
  String id,
  SelectionKey key,
  SocketChannel socketChannel)

buildTransportLayer…​FIXME

Note
 buildTransportLayer is used when SaslChannelBuilder is requested to buildChannel.

results matching ""

    No results matching ""