kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ilter P <ilterpehli...@gmail.com>
Subject Custom Token Authentication Callback
Date Fri, 09 Nov 2018 15:34:33 GMT
Hi,

I am trying to build a custom sequence to authenticate the clients.
According to documentation, I need to create 2 different Callback:

sasl.login.callback.handler.class -> I am assuming this is for the
first time connect request comes then I should create a JWT token
inside this Callback

sasl.server.callback.handler.class -> This is the one validating token


It is really not clear the use of those 2 different implementation.

So I wanted to give a try, but I am getting error from the Callback
handle function during the server is starting

My expectation, handle function should work only when a client tries
to connect ?

I am confused please help on this one

****************

Kafka version: 2.0.0

My sequence:

  - Clients will have token and send it to Kafka for verification

  - No inter-broker authentication required

Config details:

listener.security.protocol.map = INSIDE:PLAINTEXT,OUTSIDE:SASL_PLAINTEXT

listeners = INSIDE://:9092,OUTSIDE://:9094

sasl.enabled.mechanisms = [OAUTHBEARER]


ENV:

KAFKA_LISTENER_NAME_OUTSIDE_OAUTHBEARER_SASL_LOGIN_CALLBACK_HANDLER_CLASS=<Custom
Class>

KAFKA_LISTENER_NAME_OUTSIDE_OAUTHBEARER_SASL_SERVER_CALLBACK_HANDLER_CLASS=<Custom
Class>



********************


Thanks for the help

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message