Class ClusterLinkHttpAccessTokenRetriever

java.lang.Object

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

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

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.security.oauthbearer.internals.secured.OAuthBearerConfigurable, org.apache.kafka.common.security.oauthbearer.JwtRetriever

public class ClusterLinkHttpAccessTokenRetriever
extends org.apache.kafka.common.security.oauthbearer.internals.secured.HttpJwtRetriever

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.kafka.common.security.oauthbearer.internals.secured.HttpJwtRetriever

org.apache.kafka.common.security.oauthbearer.internals.secured.HttpJwtRetriever.HttpRequestFormatterAdaptor

Constructor Summary

Constructors

Constructor	Description
ClusterLinkHttpAccessTokenRetriever(String clientId, String clientSecret, String scope, String tokenEndpointUrl, boolean urlencodeHeader, boolean enableFilteringDNSResolver)
ClusterLinkHttpAccessTokenRetriever(String clientId, String clientSecret, String scope, String tokenEndpointUrl, boolean urlencodeHeader, boolean enableFilteringDNSResolver, boolean disallowLocalIps)

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> configs, String saslMechanism, List<AppConfigurationEntry> jaasConfigEntries)
String	retrieve()

Methods inherited from class org.apache.kafka.common.security.oauthbearer.internals.secured.HttpJwtRetriever

close, post

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterLinkHttpAccessTokenRetriever

public ClusterLinkHttpAccessTokenRetriever(String clientId,
 String clientSecret,
 String scope,
 String tokenEndpointUrl,
 boolean urlencodeHeader,
 boolean enableFilteringDNSResolver)

ClusterLinkHttpAccessTokenRetriever

public ClusterLinkHttpAccessTokenRetriever(String clientId,
 String clientSecret,
 String scope,
 String tokenEndpointUrl,
 boolean urlencodeHeader,
 boolean enableFilteringDNSResolver,
 boolean disallowLocalIps)

Method Details

configure

public void configure(Map<String,?> configs,
 String saslMechanism,
 List<AppConfigurationEntry> jaasConfigEntries)

Specified by:

configure in interface org.apache.kafka.common.security.oauthbearer.internals.secured.OAuthBearerConfigurable

Overrides:

configure in class org.apache.kafka.common.security.oauthbearer.internals.secured.HttpJwtRetriever

retrieve

public String retrieve()
                throws org.apache.kafka.common.security.oauthbearer.JwtRetrieverException

Specified by:

retrieve in interface org.apache.kafka.common.security.oauthbearer.JwtRetriever

Overrides:

retrieve in class org.apache.kafka.common.security.oauthbearer.internals.secured.HttpJwtRetriever

Throws:

org.apache.kafka.common.security.oauthbearer.JwtRetrieverException