Class SaslAuthenticationContext
java.lang.Object
org.apache.kafka.common.security.auth.SaslAuthenticationContext
- All Implemented Interfaces:
AuthenticationContext
-
Constructor Summary
ConstructorDescriptionSaslAuthenticationContext
(SaslServer server, SecurityProtocol securityProtocol, InetAddress clientAddress, String listenerName) SaslAuthenticationContext
(SaslServer server, SecurityProtocol securityProtocol, InetAddress clientAddress, String listenerName, Optional<SSLSession> sslSession) -
Method Summary
Modifier and TypeMethodDescriptionAddress of the authenticated clientName of the listener used for the connectionUnderlying security protocol of the authentication session.server()
Returns SSL session for the connection if security protocol is SASL_SSL.
-
Constructor Details
-
SaslAuthenticationContext
public SaslAuthenticationContext(SaslServer server, SecurityProtocol securityProtocol, InetAddress clientAddress, String listenerName) -
SaslAuthenticationContext
public SaslAuthenticationContext(SaslServer server, SecurityProtocol securityProtocol, InetAddress clientAddress, String listenerName, Optional<SSLSession> sslSession)
-
-
Method Details
-
server
-
sslSession
Returns SSL session for the connection if security protocol is SASL_SSL. If SSL mutual client authentication is enabled for the listener, peer principal can be determined usingSSLSession.getPeerPrincipal()
. -
securityProtocol
Description copied from interface:AuthenticationContext
Underlying security protocol of the authentication session.- Specified by:
securityProtocol
in interfaceAuthenticationContext
-
clientAddress
Description copied from interface:AuthenticationContext
Address of the authenticated client- Specified by:
clientAddress
in interfaceAuthenticationContext
-
listenerName
Description copied from interface:AuthenticationContext
Name of the listener used for the connection- Specified by:
listenerName
in interfaceAuthenticationContext
-