Snažím sa realizovať OAUTHBEARER ako SASL mechanizmus. Súčasťou že sa musím prepísať, tak server prihlásiť a spätný hovor obslužnú triedy. Ja používam docker, a teda nastavenie ich prostredníctvom premenných prostredia:
KAFKA_LISTENER_NAME_OUTSIDE_OAUTHBEARER_SASL_SERVER_CALLBACK_HANDLER_CLASS=[class_name]
Čo je divné je, že jasne načítava určený triedy ako som hravo robí log.warn("ctor...") v konštruktéra povedal triedy. Ale stacktrace ukazuje, že to nie je volanie handle metóda dodaného triedy, ale namiesto toho AbstractLogin$DefaultLoginHandler triedy:
[2021-11-23 17:41:57,137] WARN OAuthAuthenticateValidatorCallbackHandler - ctor: v1.1 (com.oauth2.security.oauthbearer.OAuthAuthenticateValidatorCallbackHandler) [2021-11-23 17:41:57,153] ERROR Unrecognized SASL Login callback (org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule) javax.security.auth.callback.UnsupportedCallbackException: Unrecognized SASL Login callback at org.apache.kafka.common.security.authenticator.AbstractLogin$DefaultLoginCallbackHandler.handle(AbstractLogin.java:105) at org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule.identifyToken(OAuthBearerLoginModule.java:316)
Je tam nejaké návrhy, ako na to, prečo je to nakladanie s právami triedy, ale nie ju používať? Ak som jednoducho odstrániť premenné prostredia pre obe PRIHLÁSIŤ sa/SERVER_CALLBACK_HANDLER_CLASS, rovnaká Výnimka, ale bez VAROVAŤ, ktoré dokazujú, že v triede bolo naložené. Jedna možnosť, že sa nemôžem zmieriť s je, že stacktrace zdá sa týkajú LoginCallbackHandler ale triede odvolávať je Server/ValidatorCallbackHandler; ako keby nebol schopný načítať prihlásiť spätný hovor s právami a len Validator spätný hovor handler, ale ja som dvakrát skontrolovať, že a) premenné prostredia sa týkajú správne trieda meno (login==Login && server==Validator) a že názvy tried sú skutočne správne.