public class SpireJwtTokenRetriever extends Object implements org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever
AccessTokenRetriever
that retrieves the JWT SVID from the Spire agentConstructor and Description |
---|
SpireJwtTokenRetriever(String spireAgentEndpoint,
String audience) |
public String retrieve() throws IOException
retrieve
in interface org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in interface org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever
IOException