4.10.6.3. OAuth 2.0 を使用するよう Kafka Java クライアントを設定

手順

1. OAuth 2.0 サポートのあるクライアントライブラリーを Kafka クライアントの pom.xml ファイルに追加します。

   <dependency>
    <groupId>io.strimzi</groupId>
    <artifactId>kafka-oauth-client</artifactId>
    <version>0.8.1.redhat-00004</version>
   </dependency>

2. コールバックのシステムプロパティーを設定します。

   以下に例を示します。

   System.setProperty(ClientConfig.OAUTH_TOKEN_ENDPOINT_URI, “https://AUTH-SERVER-ADDRESS/auth/realms/REALM-NAME/protocol/openid-connect/token”); 1
   System.setProperty(ClientConfig.OAUTH_CLIENT_ID, "CLIENT-NAME"); 2
   System.setProperty(ClientConfig.OAUTH_CLIENT_SECRET, "CLIENT_SECRET"); 3
   System.setProperty(ClientConfig.OAUTH_SCOPE, "SCOPE-VALUE") 4

   1

   承認サーバーのトークンエンドポイントの URI です。

   2

   クライアント ID。承認サーバーで client を作成するときに使用される名前です。

   3

   承認サーバーで client を作成するときに作成されるクライアントシークレット。

   4

   (任意設定): トークンエンドポイントからトークンを要求するための scope。認証サーバーでは、クライアントによるスコープの指定が必要になることがあります。

3. Kafka クライアント設定の TLS で暗号化された接続でOAUTHBEARER または PLAIN メカニズムを有効にします。

   以下に例を示します。

   Kafka クライアントの OAUTHBEARER の有効化

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

   Kafka クライアントの PLAIN の有効化

   props.put("sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"$CLIENT_ID_OR_ACCOUNT_NAME\" password=\"$SECRET_OR_ACCESS_TOKEN\" ;");
   props.put("security.protocol", "SASL_SSL"); 1
   props.put("sasl.mechanism", "PLAIN");

   1

   この例では、TLS 接続で SASL_SSL を使用します。ローカル開発のみでは、暗号化されていない接続で SASL_PLAINTEXT を使用します。

4. Kafka クライアントが Kafka ブローカーにアクセスできることを確認します。