Class MockSpireJwtTokenRetriever

java.lang.Object

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

All Implemented Interfaces:

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

public class MockSpireJwtTokenRetriever
extends Object
implements org.apache.kafka.common.security.oauthbearer.JwtRetriever

For testing

Constructor Summary

Constructors

Constructor	Description
MockSpireJwtTokenRetriever(String spireAgentEndpoint)

Method Summary

Modifier and Type	Method	Description
String	retrieve()
static void	updateBearerCredential(String bearerToken)

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.OAuthBearerConfigurable

close, configure

Constructor Details

MockSpireJwtTokenRetriever

public MockSpireJwtTokenRetriever(String spireAgentEndpoint)

Method Details

retrieve

public String retrieve()

Specified by:

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

updateBearerCredential

public static void updateBearerCredential(String bearerToken)