我正在 Kafka 集群中使用 SASL_SSL,并尝试配置一些客户端以从 OAuth 服务器获取令牌。我已经成功设置了我的配置,但是当我的回调处理程序面临两个选项时,我遇到了困难。你看,有两个非常相似的属性,我似乎找不到任何关于它们的详细信息:
sasl.login.callback.handler.class
和
sasl.client.callback.handler.class
这些属性要求类实现
AuthenticateCallbackHandler
从 Kafka 文档中我可以看到关于
login.callback.handler
The fully qualified name of a SASL login callback handler class that implements the AuthenticateCallbackHandler
interface. For brokers, login callback handler config must be prefixed with listener prefix and SASL
mechanism name in lower-case. For example, listener.name.sasl_ssl.scram-sha-256.sasl.login.callback.handler.class=com.example.CustomScramLoginCallbackHandler
这不是很有帮助。
client.callback.handler
似乎有相同的文档:
The fully qualified name of a SASL login callback handler class that implements the AuthenticateCallbackHandler interface.
我假设
login.callback.handler
是经纪商端道具而 client.callback.handler
是客户端道具是否正确?我应该使用哪一个来配置我的客户端(消费者/生产者)以从 OAuth 服务器请求令牌?它似乎适用于这两个属性