public class PlainSaslServer extends Object implements MultiTenantSaslServer
Modifier and Type | Class and Description |
---|---|
static class |
PlainSaslServer.PlainSaslServerFactory |
Modifier and Type | Field and Description |
---|---|
static String |
PLAIN_MECHANISM |
Constructor and Description |
---|
PlainSaslServer(List<AppConfigurationEntry> jaasContextEntries,
io.confluent.kafka.server.plugins.auth.SaslAuthenticator authenticator) |
PlainSaslServer(List<AppConfigurationEntry> jaasContextEntries,
io.confluent.kafka.server.plugins.auth.SaslAuthenticator authenticator,
org.apache.kafka.common.security.authenticator.PathAwareSniHostName sniHostName) |
Modifier and Type | Method and Description |
---|---|
String |
authenticationId() |
void |
dispose() |
byte[] |
evaluateResponse(byte[] response) |
String |
getAuthorizationID() |
String |
getMechanismName() |
Object |
getNegotiatedProperty(String propName) |
boolean |
isComplete() |
io.confluent.kafka.multitenant.TenantMetadata |
tenantMetadata() |
byte[] |
unwrap(byte[] incoming,
int offset,
int len) |
String |
userIdentifier() |
byte[] |
wrap(byte[] outgoing,
int offset,
int len) |
public static final String PLAIN_MECHANISM
public PlainSaslServer(List<AppConfigurationEntry> jaasContextEntries, io.confluent.kafka.server.plugins.auth.SaslAuthenticator authenticator)
public PlainSaslServer(List<AppConfigurationEntry> jaasContextEntries, io.confluent.kafka.server.plugins.auth.SaslAuthenticator authenticator, org.apache.kafka.common.security.authenticator.PathAwareSniHostName sniHostName)
public byte[] evaluateResponse(byte[] response) throws SaslException
evaluateResponse
in interface SaslServer
SaslException
public io.confluent.kafka.multitenant.TenantMetadata tenantMetadata()
tenantMetadata
in interface MultiTenantSaslServer
public String getAuthorizationID()
getAuthorizationID
in interface SaslServer
public String authenticationId()
authenticationId
in interface MultiTenantSaslServer
public String getMechanismName()
getMechanismName
in interface SaslServer
public Object getNegotiatedProperty(String propName)
getNegotiatedProperty
in interface SaslServer
public boolean isComplete()
isComplete
in interface SaslServer
public byte[] unwrap(byte[] incoming, int offset, int len)
unwrap
in interface SaslServer
public byte[] wrap(byte[] outgoing, int offset, int len)
wrap
in interface SaslServer
public void dispose()
dispose
in interface SaslServer
public String userIdentifier()
userIdentifier
in interface MultiTenantSaslServer