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認証情報の生成
SCHEMA REGISTRY要件
Workatoでは、メッセージスキーマのソースとしてConfluent Cloud Schema Registryを使用するユースケースにStream Governance認証情報が必要です。 スキーマソースとしてCommon data modelを使用する予定がある場合、次の手順は任意です。
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パスワードとして使用されます。
Last updated: