4.4.6.3. 将 Kafka Java 客户端配置为使用 OAuth 2.0

步骤

1. 将带有 OAuth 2.0 支持的客户端库添加到 Kafka 客户端的 pom.xml 文件中：

   <dependency>
    <groupId>io.strimzi</groupId>
    <artifactId>kafka-oauth-client</artifactId>
    <version>0.6.1.redhat-00003</version>
   </dependency>

2. 为回调配置系统属性：

   例如：

   System.setProperty(ClientConfig.OAUTH_TOKEN_ENDPOINT_URI, “https://<auth-server-address>/auth/realms/master/protocol/openid-connect/token”); 1
   System.setProperty(ClientConfig.OAUTH_CLIENT_ID, "<client-name>"); 2
   System.setProperty(ClientConfig.OAUTH_CLIENT_SECRET, "<client-secret>"); 3

   1

   授权服务器令牌端点的 URI。

   2

   客户端 ID，这是在授权服务器中创建 客户端 时使用的名称。

   3

   在授权服务器中创建 客户端 时创建的客户端机密。

3. 在 Kafka 客户端配置中的 TLS 加密连接中启用 SASL OAUTHBEARER 机制：

   例如：

   props.put("sasl.jaas.config", "org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required;");
   props.put("security.protocol", "SASL_SSL"); 1
   props.put("sasl.mechanism", "OAUTHBEARER");
   props.put("sasl.login.callback.handler.class", "io.strimzi.kafka.oauth.client.JaasClientOauthLoginCallbackHandler");

   1

   在这里，我们使用 SASL_SSL 通过 TLS 连接使用。对未加密的连接使用 SASL_PLAINTEXT。

4. 验证 Kafka 客户端可以访问 Kafka 代理。