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

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.AccessTokenRetriever, org.apache.kafka.common.security.oauthbearer.internals.secured.Initable

public class MockSpireJwtTokenRetriever
extends Object
implements org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever

For testing

Constructor Summary

Constructors

Constructor and Description
MockSpireJwtTokenRetriever(String spireAgentEndpoint)

Method Summary

Modifier and Type	Method and 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.AccessTokenRetriever

close

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

init

Constructor Detail

MockSpireJwtTokenRetriever

public MockSpireJwtTokenRetriever(String spireAgentEndpoint)

Method Detail

retrieve

public String retrieve()

Specified by:

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

updateBearerCredential

public static void updateBearerCredential(String bearerToken)