Package 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	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.AccessTokenRetriever

close

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

init

Constructor Details

MockSpireJwtTokenRetriever

public MockSpireJwtTokenRetriever(String spireAgentEndpoint)

Method Details

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)