Openflow Connector for Kafkaのその他の認証方法を構成する¶

前提条件¶

mTLS 認証を構成する前に、以下を確認します。

1. コネクタとKafkaブローカーの両方に必要な証明書を生成・構成した

2. コネクタの秘密キーと証明書を含むキーストアを作成した

3. （オプション）Kafkaブローカー証明書または証明書チェーン内の証明書を含むトラストストアを作成した。このステップは、ブローカー証明書が信頼できる認証機関（CA）によって署名されていない場合にのみ必要です。

4. サポートされているキーストア/トラストストアの形式が、 PKCS12、 JKS または BCFKS である

ステップ1: SSL コンテキストサービスを構成する¶

1. NiFi キャンバスから、 Controller Services 構成にアクセスします。

   • コネクタの処理グループをダブルクリックします。

   • キャンバス上で右クリックし、 Controller Services を選択します。

2. 新しい StandardSSLContextService を追加します。

   • 新しいコントローラーサービスを追加するには、 + をクリックします。

   • リストから StandardSSLContextService を選択します。

   • Add をクリックします。

3. SSL Context Serviceのプロパティを構成します。

   プロパティ	値
   キーストアファイル名	キーストアファイルへのフルパス（例: /path/to/client-keystore.p12）、またはアセットリファレンス
   キーストアパスワード	キーストアのパスワード
   キーストアタイプ	キーストア形式（PKCS12、 JKS、 または BCFKS）
   キーパスワード	秘密キーのパスワード（キーが暗号化されている場合）
   トラストストアファイル名	トラストストアファイルへのフルパス（例: /path/to/client-truststore.p12）、またはアセットリファレンス
   トラストストアパスワード	トラストストアのパスワード
   トラストストアタイプ	トラストストアの形式（PKCS12、 JKS、 または BCFKS）

4. SSL Context Serviceを有効にします。

   • サービスの Enable をクリックします。

   • サービスのステータスが Enabled と表示されていることを確認します。

ステップ2: Kafka3Connection サービスを構成する¶

1. 同じ Controller Services タブで、 Kafka3Connection サービスを探します。

2. 以下のプロパティを構成します。

   プロパティ	値
   セキュリティプロトコル	SSL
   SSL コンテキストサービス	ステップ1で作成した SSL Context Serviceを選択します。

3. その他のすべての Kafka3Connection サービス の設定は変更しないでください。

4. Kafka3Connection サービスを検証します。

   • サービスの Verify をクリックします。

   • サービスのステータスが Verified と表示されていることを確認します。

前提条件¶

1. Kafkaクラスターは、 IAM 認証が有効化されたAmazon MSK である必要があります。

2. クラウドにデプロイされた BYOC （Bring Your Own Cloud）構成のOpenflowで IAM 認証情報を提供する必要があります。

3. IAM ロールまたはユーザーには、必要な MSK 権限がなければいけません。

ステップ1: AmazonMSKConnectionService を作成する¶

1. NiFi キャンバスから、 Controller Services 構成にアクセスします。

   • コネクタの処理グループをダブルクリックします。

   • キャンバス上で右クリックし、 Controller Services を選択します。

2. 新しい AmazonMSKConnectionService を追加します。

   • 新しいコントローラーサービスを追加するには、 + をクリックします。

   • リストから AmazonMSKConnectionService を選択します。

   • Add をクリックします

3. AmazonMSKConnectionService プロパティを構成します。

   プロパティ	値
   SASL メカニズム	AWS_MSK_IAM
   セキュリティプロトコル	#{Kafka Security Protocol}
   ブートストラップサーバー	#{Kafka Bootstrap Servers}

4. AmazonMSKConnectionService を検証します。

   • サービスの Verify をクリックします。

   • サービスのステータスが Verified と表示されていることを確認します。

ステップ2: ConsumeKafka プロセッサーを構成する¶

1. Kafkaコネクタフローで、 ConsumeKafka プロセッサーを探します。

2. 新しい接続サービスを使用するためにプロセッサーを構成します。

   • Kafka Connection Service プロパティを ステップ1: AmazonMSKConnectionService を作成する で作成した AmazonMSKConnectionService に設定します。

ステップ3: 古いKafka Connection Serviceを削除する¶

1. Controller Services タブで、古い Kafka3Connection サービスを探します。

2. 古いサービスを無効にして削除します。

   • 古いサービスの Disable をクリックします。

   • 無効にしたら、 Delete をクリックして古いサービスを削除します。