使用 OAuthBearer 的 Kafka SASL 身份验证机制？答案

【问题标题】：Kafka SASL Authentication mechanism using OAuthBearer?使用 OAuthBearer 的 Kafka SASL 身份验证机制？
【发布时间】：2019-03-09 01:38:20
【问题描述】：

谁能帮我编写 JAAS conf 文件和 Handler 类以使用 SASL/OAUTHBEARER 进行身份验证？

另外，在kafka文档中配置的JAAS文件中这个选项的含义是什么？

unsecuredLoginStringClaim_sub="admin";

【问题讨论】：

【解决方案1】：

对于 SASL/OAUTHBEARER，JAAS 配置文件至少是：

KafkaServer {
   org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required ;
};

其他参数将由您的接口实现使用AuthenticateCallbackHandler，该接口可以接收其他参数，例如您的 OAuth 服务器主机、授权类型或您执行登录流程所需的其他信息。 unsecuredLoginStringClaim_sub="admin" 选项是这些参数之一。

如果您需要使用这种 SASL 机制设置和测试 Kafka 代理，可以查看这篇文章。 https://medium.com/@jairsjunior/how-to-setup-oauth2-mechanism-to-a-kafka-broker-e42e72839fe

【讨论】：

【解决方案2】：

请参阅https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModule.java 上的 Javadoc 以了解对 unsecuredLoginStringClaim_sub="admin" 的解释——这是一个可被您开箱即用的默认不安全回调处理程序识别的选项。

【讨论】：