public class RefreshingAccessTokenRetriever extends Object implements org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever
Constructor and Description |
---|
RefreshingAccessTokenRetriever(org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever accessTokenRetriever) |
public RefreshingAccessTokenRetriever(org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever accessTokenRetriever)
public String retrieve()
retrieve
in interface org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever