public class ClusterLinkAccessTokenRetrieverFactory extends Object
| Constructor and Description |
|---|
ClusterLinkAccessTokenRetrieverFactory() |
| Modifier and Type | Method and Description |
|---|---|
static org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever |
create(Map<String,?> configs,
Map<String,Object> jaasConfig)
Create an
AccessTokenRetriever from the given SASL and JAAS configuration. |
static org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever |
create(Map<String,?> configs,
String saslMechanism,
Map<String,Object> jaasConfig) |
public ClusterLinkAccessTokenRetrieverFactory()
public static org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever create(Map<String,?> configs, Map<String,Object> jaasConfig)
AccessTokenRetriever from the given SASL and JAAS configuration.
Note: the returned AccessTokenRetriever is not initialized
here and must be done by the caller prior to use.configs - SASL configurationjaasConfig - JAAS configurationnull AccessTokenRetriever