Class PlainSaslServer

java.lang.Object

io.confluent.kafka.server.plugins.auth.PlainSaslServer

All Implemented Interfaces:

MultiTenantSaslServer, io.confluent.kafka.security.auth.ConfluentSaslServer, SaslServer

public class PlainSaslServer
extends Object
implements MultiTenantSaslServer

SaslServer implementation for SASL/PLAIN with an authenticator provided through the constructor.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PlainSaslServer.PlainSaslServerFactory

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PLAIN_MECHANISM

Constructor Summary

Constructors

Constructor	Description
PlainSaslServer(List<AppConfigurationEntry> jaasContextEntries, io.confluent.kafka.server.plugins.auth.SaslAuthenticator authenticator, Map<String,?> props)

Method Summary

Modifier and Type	Method	Description
String	authenticationId()
Optional<String>	clientLogicalClusterId()
void	dispose()
byte[]	evaluateResponse(byte[] response)
String	getAuthorizationID()
String	getMechanismName()
Object	getNegotiatedProperty(String propName)
Optional<Boolean>	hasSslPeerCertificate()
boolean	isComplete()
Optional<String>	networkId()
Optional<org.apache.kafka.common.security.authenticator.SaslInternalConfigs.NetworkType>	networkType()
Optional<String>	organizationId()
io.confluent.kafka.multitenant.TenantMetadata	tenantMetadata()
byte[]	unwrap(byte[] incoming, int offset, int len)
String	userIdentifier()
byte[]	wrap(byte[] outgoing, int offset, int len)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

PLAIN_MECHANISM

public static final String PLAIN_MECHANISM

See Also:

• Constant Field Values

Constructor Details

PlainSaslServer

public PlainSaslServer(List<AppConfigurationEntry> jaasContextEntries,
 io.confluent.kafka.server.plugins.auth.SaslAuthenticator authenticator,
 Map<String,?> props)

Method Details

evaluateResponse

public byte[] evaluateResponse(byte[] response)
                        throws SaslException

Specified by:

evaluateResponse in interface SaslServer

Throws:

SaslException

tenantMetadata

public io.confluent.kafka.multitenant.TenantMetadata tenantMetadata()

Specified by:

tenantMetadata in interface MultiTenantSaslServer

getAuthorizationID

public String getAuthorizationID()

Specified by:

getAuthorizationID in interface SaslServer

authenticationId

public String authenticationId()

Specified by:

authenticationId in interface MultiTenantSaslServer

getMechanismName

public String getMechanismName()

Specified by:

getMechanismName in interface SaslServer

getNegotiatedProperty

public Object getNegotiatedProperty(String propName)

Specified by:

getNegotiatedProperty in interface SaslServer

isComplete

public boolean isComplete()

Specified by:

isComplete in interface SaslServer

unwrap

public byte[] unwrap(byte[] incoming,
 int offset,
 int len)

Specified by:

unwrap in interface SaslServer

wrap

public byte[] wrap(byte[] outgoing,
 int offset,
 int len)

Specified by:

wrap in interface SaslServer

dispose

public void dispose()

Specified by:

dispose in interface SaslServer

userIdentifier

public String userIdentifier()

Specified by:

userIdentifier in interface MultiTenantSaslServer

networkId

public Optional<String> networkId()

Specified by:

networkId in interface io.confluent.kafka.security.auth.ConfluentSaslServer

Specified by:

networkId in interface MultiTenantSaslServer

organizationId

public Optional<String> organizationId()

Specified by:

organizationId in interface MultiTenantSaslServer

networkType

public Optional<org.apache.kafka.common.security.authenticator.SaslInternalConfigs.NetworkType> networkType()

Specified by:

networkType in interface MultiTenantSaslServer

hasSslPeerCertificate

public Optional<Boolean> hasSslPeerCertificate()

Specified by:

hasSslPeerCertificate in interface MultiTenantSaslServer

clientLogicalClusterId

public Optional<String> clientLogicalClusterId()

Specified by:

clientLogicalClusterId in interface io.confluent.kafka.security.auth.ConfluentSaslServer

Specified by:

clientLogicalClusterId in interface MultiTenantSaslServer