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

Class AsyncHttpsJwks

java.lang.Object

org.jose4j.jwk.HttpsJwks

io.confluent.kafka.clients.plugins.auth.jwt.AsyncHttpsJwks

All Implemented Interfaces:

Closeable, AutoCloseable

public final class AsyncHttpsJwks
extends org.jose4j.jwk.HttpsJwks
implements Closeable

Extends HttpsJwks with an asynchronous refresh implementation.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_REFRESH_INTERVAL_MS

Constructor Summary

Constructors

Constructor	Description
AsyncHttpsJwks(String location)
AsyncHttpsJwks(String location, boolean unsafeAllowed, long refreshIntervalMs)
AsyncHttpsJwks(URI location)	Create a new HttpsJwks that can be used to retrieve JWKs from the given location asynchronously.
AsyncHttpsJwks(org.jose4j.http.SimpleGet httpGet, String location, boolean unsafeAllowed, long refreshIntervalMs)

Method Summary

Modifier and Type	Method	Description
void	close()
List<org.jose4j.jwk.JsonWebKey>	getJsonWebKeys()
boolean	isRunning()
void	refresh()

Methods inherited from class org.jose4j.jwk.HttpsJwks

getLocation, setDefaultCacheDuration, setRefreshReprieveThreshold, setRetainCacheOnErrorDuration, setSimpleHttpGet

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_REFRESH_INTERVAL_MS

public static final long DEFAULT_REFRESH_INTERVAL_MS

See Also:

• Constant Field Values

Constructor Details

AsyncHttpsJwks

public AsyncHttpsJwks(URI location)

Create a new HttpsJwks that can be used to retrieve JWKs from the given location asynchronously.

Parameters:

location - the HTTPS URI of the JSON Web Key Set

AsyncHttpsJwks

public AsyncHttpsJwks(String location)

AsyncHttpsJwks

public AsyncHttpsJwks(String location,
 boolean unsafeAllowed,
 long refreshIntervalMs)

AsyncHttpsJwks

public AsyncHttpsJwks(org.jose4j.http.SimpleGet httpGet,
 String location,
 boolean unsafeAllowed,
 long refreshIntervalMs)

Method Details

refresh

public void refresh()

Overrides:

refresh in class org.jose4j.jwk.HttpsJwks

getJsonWebKeys

public List<org.jose4j.jwk.JsonWebKey> getJsonWebKeys()

Overrides:

getJsonWebKeys in class org.jose4j.jwk.HttpsJwks

isRunning

public boolean isRunning()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable