org.apache.kafka.common.security.oauthbearer.secured

Class AccessTokenRetrieverFactory

java.lang.Object

org.apache.kafka.common.security.oauthbearer.secured.AccessTokenRetrieverFactory

public class AccessTokenRetrieverFactory
extends Object

Constructor Summary

Constructors

Constructor and Description
AccessTokenRetrieverFactory()

Method Summary

Modifier and Type	Method and Description
static AccessTokenRetriever	create(Map<String,?> configs, Map<String,Object> jaasConfig) Create an AccessTokenRetriever from the given SASL and JAAS configuration.
static AccessTokenRetriever	create(Map<String,?> configs, String saslMechanism, Map<String,Object> jaasConfig)

Methods inherited from class java.lang.Object

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

Constructor Detail

AccessTokenRetrieverFactory

public AccessTokenRetrieverFactory()

Method Detail

create

public static AccessTokenRetriever create(Map<String,?> configs,
                                          Map<String,Object> jaasConfig)

Create an 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.

Parameters:

configs - SASL configuration

jaasConfig - JAAS configuration

Returns:

Non-null AccessTokenRetriever

create

public static AccessTokenRetriever create(Map<String,?> configs,
                                          String saslMechanism,
                                          Map<String,Object> jaasConfig)