public class Credentials
extends java.lang.Object
Constructor and Description |
---|
Credentials() |
Modifier and Type | Method and Description |
---|---|
void |
storeCredentials(java.lang.String clientId,
org.apache.kafka.common.security.auth.KafkaPrincipal principal)
Store credentials to communicate them from PLAIN callback handler to OAuthKafkaPrincipalBuilder when OAuth over PLAIN is used.
|
org.apache.kafka.common.security.auth.KafkaPrincipal |
takeCredentials(java.lang.String clientId)
Take credentials in order to associate them with PlainSaslServer
|
public void storeCredentials(java.lang.String clientId, org.apache.kafka.common.security.auth.KafkaPrincipal principal)
clientId
- A clientId as passed to the 'username' parameter of SASL/PLAIN mechanismprincipal
- The OAuthKafkaPrincipal containing the validated tokenpublic org.apache.kafka.common.security.auth.KafkaPrincipal takeCredentials(java.lang.String clientId)
clientId
- A clientId as passed to the 'username' parameter of SASL/PLAIN mechanismCopyright © 2021. All rights reserved.