io.confluent.kafka.server.plugins.auth.token

Class CompositeBearerValidatorCallbackHandler

java.lang.Object

io.confluent.kafka.server.plugins.auth.token.CompositeBearerValidatorCallbackHandler

All Implemented Interfaces:

CallbackHandler, org.apache.kafka.common.security.auth.AuthenticateCallbackHandler

public class CompositeBearerValidatorCallbackHandler
extends Object
implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler

A CallbackHandler that recognizes CompositeBearerValidatorCallbackHandler for validating Authentication Tokens issued by Confluent and external Identity Provider.

It uses TokenBearerValidatorCallbackHandler for validating Confluent issued tokens. And OAuthBearerValidatorCallbackHandler for validating Identity Provder issued tokens.

This class must be explicitly set via the listener.name.sasl_[plaintext|ssl].oauthbearer.sasl.server.callback.handler.class broker configuration property.

Constructor Summary

Constructors

Constructor and Description
CompositeBearerValidatorCallbackHandler()

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(Map<String,?> configs, String saslMechanism, List<AppConfigurationEntry> jaasConfigEntries)
void	handle(Callback[] callbacks)

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeBearerValidatorCallbackHandler

public CompositeBearerValidatorCallbackHandler()

Method Detail

configure

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

Specified by:

configure in interface org.apache.kafka.common.security.auth.AuthenticateCallbackHandler

handle

public void handle(Callback[] callbacks)
            throws UnsupportedCallbackException,
                   IOException

Specified by:

handle in interface CallbackHandler

Throws:

UnsupportedCallbackException

IOException

close

public void close()

Specified by:

close in interface org.apache.kafka.common.security.auth.AuthenticateCallbackHandler