注釈

このコネクタは、 Snowflakeコネクタ規約に従うものとします。

Kafka用Snowflake Openflowコネクタ：AWS MSK IAM 認証の構成¶

AWS MSK IAM 認証では、 AWS Identity and Access Management（IAM）を使用してAmazon Managed Streaming for Apache Kafka（MSK）を認証できます。

前提条件¶

Kafkaクラスターは、 IAM 認証が有効化されたAmazon MSK である必要があります。
クラウドにデプロイされた BYOC （Bring Your Own Cloud）構成のOpenflowで IAM 認証情報を提供する必要があります。
IAM ロールまたはユーザーには、必要な MSK 権限がなければいけません。

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

Openflowキャンバスから、コントローラーサービス構成にアクセスします。

コネクタの処理グループをダブルクリックします。
キャンバスを右クリックして、コントローラーサービスを選択します。

新しい AmazonMSKConnectionService を追加します：

+ を選択して、新しいコントローラーサービスを追加します。
リストから AmazonMSKConnectionService を選択します。
追加を選択します。

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


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

AmazonMSKConnectionService を検証します。

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

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

Kafkaコネクタで ConsumeKafka プロセッサーを見つけます。
新しい接続サービスを使用するためにプロセッサーを構成します。

Kafka接続サービス プロパティをステップ1: AmazonMSKConnectionService を作成するで作成した AmazonMSKConnectionService に設定します。

ステップ3（オプション）：古いKafka接続サービスを削除¶

コントローラーサービスタブで、古い Kafka3Connection サービスを見つけます。
古いサービスを無効にして削除します。
1. 古いサービスで無効を選択します。
2. 無効にした後、削除を選択して古いサービスを削除します。