Package org.apache.kafka.common.security.oauthbearer

Class DefaultJwtValidator

java.lang.Object

org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

All Implemented Interfaces:

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

public class DefaultJwtValidator
extends Object
implements JwtValidator

This JwtValidator uses the delegation approach, instantiating and delegating calls to a more concrete implementation. The underlying implementation is determined by the presence/absence of the VerificationKeyResolver: if it's present, a BrokerJwtValidator is created, otherwise a ClientJwtValidator is created.

Constructor Summary

Constructors

Constructor	Description
DefaultJwtValidator()
DefaultJwtValidator(org.apache.kafka.common.security.oauthbearer.internals.secured.CloseableVerificationKeyResolver verificationKeyResolver)

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs, String saslMechanism, List<AppConfigurationEntry> jaasConfigEntries)
OAuthBearerToken	validate(String accessToken)	Accepts an OAuth JWT access token in base-64 encoded format, validates, and returns an OAuthBearerToken.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultJwtValidator

public DefaultJwtValidator()

DefaultJwtValidator

public DefaultJwtValidator(org.apache.kafka.common.security.oauthbearer.internals.secured.CloseableVerificationKeyResolver verificationKeyResolver)

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

validate

public OAuthBearerToken validate(String accessToken)
                          throws JwtValidatorException

Description copied from interface: JwtValidator

Accepts an OAuth JWT access token in base-64 encoded format, validates, and returns an OAuthBearerToken.

Specified by:

validate in interface JwtValidator

Parameters:

accessToken - Non-null JWT access token

Returns:

OAuthBearerToken

Throws:

JwtValidatorException - Thrown on errors performing validation of given token

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

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

Throws:

IOException