セットアップガイド
以下の手順で、Apache Kafka を Connect AI アカウントに接続します：1
Connect AI のナビゲーションメニューから Sources ページを開きます。
2
右上の + Add Connection をクリックします。
3
検索フィールドに Apache Kafka と入力し、データソース名をクリックします。
4
新しいコネクションの Basic Settings タブで、コネクション名を入力するかデフォルトの名前をそのまま使用します。
5
プロバイダーが Apache Kafka クラスターへの初期接続を確立するために使用する Bootstrap Servers を入力します。
6
（オプション）プロバイダーが Apache Kafka ブローカーへ接続する際に SSL/TLS をネゴシエートするには、Use SSL をオンにします。
7
Type Detection Scheme を選択します。これは、プロバイダーが各トピックの利用可能なフィールドおよびデータ型を判定する方法を指定します。続けて、以下の該当するセクションに進みます。
タイプ検出スキーム
- None
- RowScan
- SchemaRegistry
- SchemaRegistryAggregate
- MessageOnly
1
このタイプ検出スキームでは、追加の設定は必要ありません。
2
プロバイダーが Apache Kafka ブローカーへ接続する際に使用する Auth Scheme を選択し、次のセクションに進みます。
1
このタイプ検出スキームでは、追加の設定は必要ありません。
2
プロバイダーが Apache Kafka ブローカーへ接続する際に使用する Auth Scheme を選択し、次のセクションに進みます。
1
スキーマレジストリのエンドポイントである Registry URL を入力します。このプロパティが指定されると、プロバイダーはサーバーから Avro および JSON スキーマを読み取ることができます。
2
プロバイダーが Apache Kafka トピックのキーおよび値スキーマを取得するために使用する Registry Service を選択します。オプションは Confluent と AWSGlue です。
3
プロバイダーがスキーマレジストリに接続する際に使用する Registry Auth Scheme を選択します。オプションは None、Basic、SSLCertificate です。Basic を選択した場合は、スキーマレジストリへの認証に使用する Registry User と Registry Password も入力します。
4
（オプション）Schema Merge Mode を選択します。これは、プロバイダーが複数バージョンを持つスキーマをどのように公開するかを指定します。オプションは None と Simple です。
5
（オプション）Non Registry Type Detection Scheme を選択します。これは、スキーマレジストリにスキーマがないトピックに使用するタイプ検出スキームを指定します。オプションは Disabled、None、RowScan、MessageOnly です。
6
プロバイダーが Apache Kafka ブローカーへ接続する際に使用する Auth Scheme を選択し、次のセクションに進みます。
1
（オプション）Non Registry Type Detection Scheme を選択します。これは、スキーマレジストリにスキーマがないトピックに使用するタイプ検出スキームを指定します。オプションは Disabled、None、RowScan、MessageOnly です。
2
プロバイダーが Apache Kafka ブローカーへ接続する際に使用する Auth Scheme を選択し、認証 セクションに進みます。
1
このタイプ検出スキームでは、追加の設定は必要ありません。
2
プロバイダーが Apache Kafka ブローカーへ接続する際に使用する Auth Scheme を選択し、次のセクションに進みます。
認証
- None
- Plain
- SCRAM
- SCRAM-SHA-512
- Kerberos
- SSLCertificate
- KafkaOAuthClient
- AzureAD
- AzureServicePrincipal
- AzureServicePrincipalCert
- OAuthJWT
- AWSWorkloadIdentity
- AzureWorkloadIdentity
1
この認証スキームでは、追加の設定は必要ありません。
2
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
Apache Kafka ブローカーへの認証に使用するユーザー名 User を入力します。
2
Apache Kafka への認証に使用する Password を入力します。
3
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
Apache Kafka ブローカーへの認証に使用するユーザー名 User を入力します。
2
Apache Kafka への認証に使用する Password を入力します。
3
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
Apache Kafka ブローカーへの認証に使用するユーザー名 User を入力します。
2
Apache Kafka への認証に使用する Password を入力します。
3
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
Apache Kafka ブローカーの完全な Kerberos サービスプリンシパル名（SPN）である Kerberos SPN を入力します。
2
Apache Kafka ブローカーへの認証時に使用する Kerberos Service Name を入力します。
3
（オプション）認証に使用する Kerberos プリンシパルと暗号化キーを含む keytab ファイルへのパスである Kerberos Keytab File を入力します。
4
（オプション）keytab ファイルの代わりに Kerberos チケットキャッシュを使用して認証するには、Use Kerberos Ticket Cache をオンにします。
5
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
Apache Kafka ブローカーへの認証に使用する SSL Client Cert を入力します。
2
SSL クライアント証明書の形式を指定する SSL Client Cert Type を選択します。オプションは JKSFILE、PFXFILE、PEMKEY_FILE、PEMKEY_BLOB です。
3
（オプション）SSL Client Cert で指定された証明書を復号するために使用する SSL Client Cert Password を入力します。
4
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
カスタム OAuth アプリケーションに割り当てられた OAuth Client Id（コンシューマーキーとも呼ばれます）を入力します。この ID は、認証時に OAuth 認可サーバーに対してアプリケーションを識別するために必要です。
2
カスタム OAuth アプリケーションに割り当てられた OAuth Client Secret を入力します。この機密値は、OAuth 認可サーバーに対してアプリケーションを認証するために使用されます。
3
OAuth アクセストークンを取得する元の OAuth Access Token URL を入力します。
4
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
データへのアクセスに使用される Apache Kafka テナントを識別する Azure Tenant を入力します。このフィールドは、テナントのドメイン名（例：contoso.onmicrosoft.com）またはそのディレクトリ（テナント）ID を受け付けます。
2
カスタム OAuth アプリケーションに割り当てられた OAuth Client Id（コンシューマーキーとも呼ばれます）を入力します。この ID は、認証時に OAuth 認可サーバーに対してアプリケーションを識別するために必要です。
3
カスタム OAuth アプリケーションに割り当てられた OAuth Client Secret を入力します。この機密値は、OAuth 認可サーバーに対してアプリケーションを認証するために使用されます。
4
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
データへのアクセスに使用される Apache Kafka テナントを識別する Azure Tenant を入力します。このフィールドは、テナントのドメイン名（例：contoso.onmicrosoft.com）またはそのディレクトリ（テナント）ID を受け付けます。
2
カスタム OAuth アプリケーションに割り当てられた OAuth Client Id（コンシューマーキーとも呼ばれます）を入力します。この ID は、認証時に OAuth 認可サーバーに対してアプリケーションを識別するために必要です。
3
カスタム OAuth アプリケーションに割り当てられた OAuth Client Secret を入力します。この機密値は、OAuth 認可サーバーに対してアプリケーションを認証するために使用されます。
4
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
データへのアクセスに使用される Apache Kafka テナントを識別する Azure Tenant を入力します。このフィールドは、テナントのドメイン名（例：contoso.onmicrosoft.com）またはそのディレクトリ（テナント）ID を受け付けます。
2
カスタム OAuth アプリケーションに割り当てられた OAuth Client Id（コンシューマーキーとも呼ばれます）を入力します。この ID は、認証時に OAuth 認可サーバーに対してアプリケーションを識別するために必要です。
3
カスタム OAuth アプリケーションに割り当てられた OAuth Client Secret を入力します。この機密値は、OAuth 認可サーバーに対してアプリケーションを認証するために使用されます。
4
クライアント証明書の JWT 証明書ストアの名前である OAuth JWT Cert を入力します。
5
JWT 証明書を含むキーストアの種類を指定する OAuth JWT Cert Type を選択します。オプションは PFXBLOB、JKSBLOB、PEMKEY_BLOB、PUBLIC_KEY_BLOB、SSHPUBLIC_KEY_BLOB、XMLBLOB、BCFKSBLOB、GOOGLEJSONBLOB です。
6
（オプション）OAuth JWT Cert Password を入力します。これは、パスワード保護された証明書ストアへのアクセスに使用する OAuth JWT 証明書のパスワードです。証明書ストアがパスワードを必要としない場合は、このプロパティを空白のままにします。
7
（オプション）ストア内で一致する証明書を検索するために使用する OAuth JWT 証明書の OAuth JWT Cert Subject を入力します。部分一致、および最初の証明書を選択するワイルドカード ’*’ をサポートします。
8
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
クライアント証明書の JWT 証明書ストアの名前である OAuth JWT Cert を入力します。
2
JWT 証明書を含むキーストアの種類を指定する OAuth JWT Cert Type を選択します。オプションは PFXBLOB、JKSBLOB、PEMKEY_BLOB、PUBLIC_KEY_BLOB、SSHPUBLIC_KEY_BLOB、XMLBLOB、BCFKSBLOB、GOOGLEJSONBLOB です。
3
（オプション）OAuth JWT Cert Password を入力します。これは、パスワード保護された証明書ストアへのアクセスに使用する OAuth JWT 証明書のパスワードです。証明書ストアがパスワードを必要としない場合は、このプロパティを空白のままにします。
4
（オプション）ストア内で一致する証明書を検索するために使用する OAuth JWT 証明書の OAuth JWT Cert Subject を入力します。部分一致、および最初の証明書を選択するワイルドカード ’*’ をサポートします。
5
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
AWS 経由で Workload Identity Federation を使用する際に提供する設定プロパティである AWS Workload Identity Config を入力します。
2
Workload Identity Federation プールの ID である Workload Pool Id を入力します。
3
Workload Identity Federation プールをホストする Google Cloud プロジェクトの ID である Workload Project Id を入力します。
4
Workload Identity Federation プールプロバイダーの ID である Workload Provider Id を入力します。
5
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
1
Azure 経由で Workload Identity Federation を使用する際に提供する設定プロパティである Azure Workload Identity Config を入力します。
2
Workload Identity Federation プールの ID である Workload Pool Id を入力します。
3
Workload Identity Federation プールをホストする Google Cloud プロジェクトの ID である Workload Project Id を入力します。
4
Workload Identity Federation プールプロバイダーの ID である Workload Provider Id を入力します。
5
Connect AI Add Connection ページ上部の、Save & Test をクリックします。
- 接続テストに成功すると、コネクションが作成されたことを示すConnection successfully saved というメッセージが表示されます。Edit Connection ページのStatus もAuthenticated に変わります。Edit Connection ページの右ペインにあるData Model タブで、成功したコネクションのデータモデルを表示します。
- 接続テストに失敗した場合は、入力したログイン情報に余分なスペースや文字がないかを確認してください。Connect AI は、データが不足している必須フィールドの下にエラーメッセージを表示します。一部のデータソースでは、ソースのWeb サイトに直接サインインする必要があります。サインインしていない場合は、Sign in ボタンの下にエラーメッセージが表示されます。エラーを修正し、もう一度試してください。
- 失敗したコネクションは下書きとして保存され、Status はNot Authenticated になります。後でコネクションに戻って認証することができます。
詳細について
Connect AI と Apache Kafka の連携の詳細動作については、こちらのページを参照してください。このコネクタを試してみませんか？Connect AI の無料アカウントを作成して、最初のコネクションを数分でセットアップします。