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

Class ClusterLinkHttpAccessTokenRetriever

java.lang.Object

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

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

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever, org.apache.kafka.common.security.oauthbearer.internals.secured.Initable

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

Field Summary

Fields inherited from class org.apache.kafka.common.security.oauthbearer.internals.secured.HttpAccessTokenRetriever

AUTHORIZATION_HEADER

Constructor Summary

Constructors

Constructor	Description
ClusterLinkHttpAccessTokenRetriever(String clientId, String clientSecret, String scope, SSLSocketFactory sslSocketFactory, String tokenEndpointUrl, long loginRetryBackoffMs, long loginRetryBackoffMaxMs, Integer loginConnectTimeoutMs, Integer loginReadTimeoutMs, boolean urlencodeHeader)

Method Summary

Modifier and Type	Method	Description
String	retrieve()

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

close, post

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.security.oauthbearer.internals.secured.Initable

init

Constructor Details

ClusterLinkHttpAccessTokenRetriever

public ClusterLinkHttpAccessTokenRetriever(String clientId,
 String clientSecret,
 String scope,
 SSLSocketFactory sslSocketFactory,
 String tokenEndpointUrl,
 long loginRetryBackoffMs,
 long loginRetryBackoffMaxMs,
 Integer loginConnectTimeoutMs,
 Integer loginReadTimeoutMs,
 boolean urlencodeHeader)

Method Details

retrieve

public String retrieve()
                throws IOException

Specified by:

retrieve in interface org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever

Overrides:

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

Throws:

IOException