セットアップガイド
以下の手順で、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 Apache Kafka 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 Apache Kafka 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 Apache Kafka 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 Apache Kafka 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 Apache Kafka 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 Apache Kafka 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 Apache Kafka 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 Apache Kafka 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 Apache Kafka 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 Apache Kafka 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 Apache Kafka 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 Apache Kafka 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 Apache Kafka 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 の連携の詳細動作については、こちらのページを参照してください。このソースをAI でご利用ください。 クイックスタートの手順に従い、Claude、ChatGPT、Copilot、またはその他のAI クライアントをMCP 経由でこのソースに接続してください。アプリケーションのモデルリクエストを、ガバナンスされた単一のエンドポイント経由でルーティングするには、LLM Gateway を参照してください。Connect AI を初めてご利用になる場合は、Connect AI の無料アカウントを作成し、わずか数分で最初のコネクション設定を完了できます。