Package io.confluent.kafka.clients.plugins.auth.oauth

Class ClusterLinkAccessTokenRetrieverFactory

java.lang.Object

io.confluent.kafka.clients.plugins.auth.oauth.ClusterLinkAccessTokenRetrieverFactory

public class ClusterLinkAccessTokenRetrieverFactory
extends Object

Constructor Summary

Constructors

Constructor	Description
ClusterLinkAccessTokenRetrieverFactory()

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever	create(Map<String,?> configs, String saslMechanism, Map<String,Object> jaasConfig)
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.

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterLinkAccessTokenRetrieverFactory

public ClusterLinkAccessTokenRetrieverFactory()

Method Details

create

public 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. 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 org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever create(Map<String,?> configs,
 String saslMechanism,
 Map<String,Object> jaasConfig)