Package io.confluent.kafka.common.multitenant.oauth

Class OAuthBearerJwsToken

java.lang.Object

io.confluent.kafka.common.multitenant.oauth.OAuthBearerJwsToken

All Implemented Interfaces:

org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

public class OAuthBearerJwsToken
extends Object
implements org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AUD_CLAIM
static final String	AUD_CLAIM_VALUE_CONTROL_PLANE
static final String	OAUTH_AUTHORIZED_PARTY
static final String	OAUTH_EXTERNAL_IDENTITY_ID
static final String	OAUTH_IDENTITY_POOL_PROPERTY_KEY
static final String	OAUTH_IDENTITY_POOL_PROVIDER_ID_PROPERTY_KEY
static final String	OAUTH_MAY_ACT_CLAIM
static final String	OAUTH_NEGOTIATED_LOGICAL_CLUSTER_PROPERTY_KEY
static final String	OAUTH_ORG_RESOURCE_ID_CLAIM
static final String	USER_RESOURCE_ID_CLAIM

Constructor Summary

Constructors

Constructor	Description
OAuthBearerJwsToken(String value, Set<String> scope, long lifetimeMs, String principalName, Long startTimeMs)
OAuthBearerJwsToken(String value, Set<String> scope, long lifetimeMs, String principalName, Long startTimeMs, Map<String,Object> jwtClaims)
OAuthBearerJwsToken(String value, Set<String> scope, long lifetimeMs, String principalName, Long startTimeMs, Map<String,Object> jwtClaims, String issuer)

Method Summary

Modifier and Type	Method	Description
String	issuer()
Map<String,Object>	jwtClaims()
long	lifetimeMs()
String	principalName()
Set<String>	scope()
Long	startTimeMs()
String	value()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

OAUTH_AUTHORIZED_PARTY

public static final String OAUTH_AUTHORIZED_PARTY

See Also:

• Constant Field Values

OAUTH_NEGOTIATED_LOGICAL_CLUSTER_PROPERTY_KEY

public static final String OAUTH_NEGOTIATED_LOGICAL_CLUSTER_PROPERTY_KEY

See Also:

• Constant Field Values

USER_RESOURCE_ID_CLAIM

public static final String USER_RESOURCE_ID_CLAIM

See Also:

• Constant Field Values

OAUTH_IDENTITY_POOL_PROPERTY_KEY

public static final String OAUTH_IDENTITY_POOL_PROPERTY_KEY

See Also:

• Constant Field Values

OAUTH_IDENTITY_POOL_PROVIDER_ID_PROPERTY_KEY

public static final String OAUTH_IDENTITY_POOL_PROVIDER_ID_PROPERTY_KEY

See Also:

• Constant Field Values

OAUTH_ORG_RESOURCE_ID_CLAIM

public static final String OAUTH_ORG_RESOURCE_ID_CLAIM

See Also:

• Constant Field Values

AUD_CLAIM_VALUE_CONTROL_PLANE

public static final String AUD_CLAIM_VALUE_CONTROL_PLANE

See Also:

• Constant Field Values

AUD_CLAIM

public static final String AUD_CLAIM

See Also:

• Constant Field Values

OAUTH_MAY_ACT_CLAIM

public static final String OAUTH_MAY_ACT_CLAIM

See Also:

• Constant Field Values

OAUTH_EXTERNAL_IDENTITY_ID

public static final String OAUTH_EXTERNAL_IDENTITY_ID

See Also:

• Constant Field Values

Constructor Details

OAuthBearerJwsToken

public OAuthBearerJwsToken(String value,
 Set<String> scope,
 long lifetimeMs,
 String principalName,
 Long startTimeMs)

OAuthBearerJwsToken

public OAuthBearerJwsToken(String value,
 Set<String> scope,
 long lifetimeMs,
 String principalName,
 Long startTimeMs,
 Map<String,Object> jwtClaims)

OAuthBearerJwsToken

public OAuthBearerJwsToken(String value,
 Set<String> scope,
 long lifetimeMs,
 String principalName,
 Long startTimeMs,
 Map<String,Object> jwtClaims,
 String issuer)

Method Details

value

public String value()

Specified by:

value in interface org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

scope

public Set<String> scope()

Specified by:

scope in interface org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

lifetimeMs

public long lifetimeMs()

Specified by:

lifetimeMs in interface org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

principalName

public String principalName()

Specified by:

principalName in interface org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

startTimeMs

public Long startTimeMs()

Specified by:

startTimeMs in interface org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

jwtClaims

public Map<String,Object> jwtClaims()

issuer

public String issuer()