Confluent Cloud
Confluent Cloudは、Apache Kafkaを基盤としたフルマネージドのイベントストリーミングプラットフォームです。クラウドネイティブでスケーラブル、かつ高可用性のKafkaプラットフォームを提供し、Kafkaクラスターのデプロイメント、管理、運用を簡素化します。
Confluent Cloudコネクターを使用すると、リアルタイムのデータパイプラインとストリーミングアプリケーションを構築できます。 Confluent Cloud Schema Registryと連携し、Kafkaのスキーマ管理を提供し、スキーマの進化に合わせてデータの標準化と互換性を確保します。
APIバージョン
Confluent CloudコネクターはConfluent Cloud APIを使用します。
Confluent Cloudへの接続方法
Workatoは、SASL/PLAIN認証を使用したConfluent Cloudへの接続をサポートしています。
SASL/PLAIN認証
Confluent Cloudへのコネクションを確立するには、次の手順を実行します。
Workatoアカウントにサインインし、Confluent Cloudコネクションを追加する予定のプロジェクトに移動します。
作成>コネクションをクリックするか、C+Cを押します。コネクションとしてConfluent Cloudを選択します。
表示されたフィールドに次の情報を入力します。
コネクションを設定
コネクション名
このコネクションに、接続先のConfluent Cloudインスタンスを識別する一意の名前を付けます。
シードブローカー
host:port形式で、シードブローカーのカンマ区切りリストを指定します。ユーザー名
SASL/PLAIN認証のユーザー名を指定します。詳細については、SASL/PLAIN認証情報の生成に関するガイドを参照してください。
パスワード
SASL/PLAIN認証のパスワードを指定します。詳細については、SASL/PLAIN認証情報の生成に関するガイドを参照してください。
Stream Governance
表示をクリックして、非表示のフィールドを展開します。メッセージスキーマのソースとしてConfluent Cloud Schema Registryを使用する予定がある場合は、設定のこの部分が必要です。詳細については、Stream Governance認証情報の生成に関するガイドを参照してください。
Stream Governance API URL
Stream Governance API(Schema RegistryおよびStream Catalog API)のURLを指定します。
Stream Governanceユーザー名
スキーマレジストリのユーザー名を指定します。この値は、Confluent CloudのStream Governance APIキー名です。
Stream Governanceパスワード
スキーマレジストリのパスワードを指定します。これは、Confluent CloudのStream Governance APIキーシークレットです。
接続をクリックします。
SASL/PLAIN認証情報の生成
SASL/PLAIN認証情報を生成するには、次の手順を実行します。
Confluent Cloudアカウントにサインインします。
左側のパネルでEnvironmentsを選択し、該当するKafka Clusterをクリックして概要ページを開きます。
クラスターを選択
左側のパネルでクラスター設定を選択します。
ブートストラップサーバーエントリを見つけます。これにより、Kafkaクライアントを設定するために必要なホストとポートの組み合わせのリストが提供されます。通常はURLのリストのように表示されます。例: pkd-lzurc.us-west1.gcp.confluent.cloud:9091。各エントリはホストとポートで構成されます。これがシードブローカーの値です。
ブートストラップサーバー/シードブローカーのエントリを見つける
左側のナビゲーションバーからAPIキーを選択します。
左側のパネルからAPIキーを選択
+ キーを追加をクリックして、新しいAPIキーを作成します。
APIキーとAPIシークレットをコピーします。これらの値は、Workatoコネクション設定でそれぞれユーザー名とパスワードとして使用されます。
Stream Governance認証情報の生成
Stream Governance認証情報を生成するには、次の手順を実行します。
Confluent Cloudアカウントにサインインします。
左側のナビゲーションバーからEnvironmentsを選択し、使用する予定のEnvironmentをクリックします。
Environmentsを開く
右側のパネルにあるStream Governance APIを見つけます。エンドポイントの値をコピーします。これは、Workatoコネクション設定のStream Governance API URLです。
エンドポイント値をコピー
Stream Governance APIセクションの認証情報で、{N}キーをクリックします。
{N}キーをクリック
+ キーを追加をクリックして、新しいStream Governance APIキーを作成します。
APIキーとAPIシークレットをコピーします。これらの値は、Workatoコネクション設定でそれぞれStream Governanceユーザー名とStream Governanceパスワードとして使用されます。
SCHEMA REGISTRY要件
Workatoでは、メッセージスキーマのソースとしてConfluent Cloud Schema Registryを使用するユースケースにStream Governance認証情報が必要です。スキーマソースとしてCommon data modelを使用する予定がある場合、次の手順は任意です。
最終更新日: