Class UamiJwtRetriever

java.lang.Object

io.confluent.security.auth.client.oauth.UamiJwtRetriever

All Implemented Interfaces:

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

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

This class implements a JwtRetriever for Azure UAMI. See https://learn.microsoft.com/en-us/entra/identity/managed-identities-azure-resources/how-to-use-vm-token for more info.

Constructor Summary

Constructors

Constructor	Description
UamiJwtRetriever()
UamiJwtRetriever(org.apache.kafka.common.utils.Time time, HttpClient httpClient)

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> configs, String saslMechanism, List<AppConfigurationEntry> jaasConfigEntries)
String	retrieve()	Retrieves a JWT token in its serialized form.

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

Constructor Details

UamiJwtRetriever

public UamiJwtRetriever()

UamiJwtRetriever

public UamiJwtRetriever(org.apache.kafka.common.utils.Time time,
 HttpClient httpClient)

Method Details

configure

public void configure(Map<String,?> configs,
 String saslMechanism,
 List<AppConfigurationEntry> jaasConfigEntries)

Specified by:

configure in interface org.apache.kafka.common.security.oauthbearer.internals.secured.OAuthBearerConfigurable

retrieve

public String retrieve()
                throws org.apache.kafka.common.security.oauthbearer.JwtRetrieverException

Retrieves a JWT token in its serialized form.

Specified by:

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

Returns:

Serialized JWT token for Azure UAMI

Throws:

org.apache.kafka.common.security.oauthbearer.JwtRetrieverException