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 and Description
ClusterLinkAccessTokenRetrieverFactory()

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterLinkAccessTokenRetrieverFactory

public ClusterLinkAccessTokenRetrieverFactory()

Method Detail

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)