Confluent Cloud

Confluent Cloud (opens new window) は、Apache Kafka に基づいたフルマネージドのイベントストリーミングプラットフォームです。クラウドネイティブでスケーラブルかつ高可用性の Kafka プラットフォームを提供し、Kafka クラスターのデプロイ、管理、運用を簡素化します。

Confluent Cloud コネクタにより、リアルタイムのデータパイプラインやストリーミングアプリケーションを構築できます。これは、Kafka のスキーマ管理を提供し、スキーマの進化に伴うデータの標準化と互換性を保証する Confluent Cloud Schema Registry (opens new window) と統合しています。

API バージョン

Confluent Cloud コネクタは Confluent Cloud API を使用します。

Confluent Cloud への接続方法

Workato は、SASL/PLAIN 認証 を使用して Confluent Cloud に接続することをサポートしています。

SASL/PLAIN 認証

以下の手順で Confluent Cloud への接続を確立します：

1

Workato アカウントにサインインし、Confluent Cloud の接続を追加する予定のプロジェクトに移動します。

2

Create > Connection をクリックします。Confluent Cloud を接続として選択します。

3

提供されたフィールドに次の情報を入力します：

Configure your connection

• Connection name

• この接続に一意の名前を付けて、どの Confluent Cloud インスタンスに接続されているか識別します。

• Seed brokers

• host:port の形式でカンマ区切りのシードブローカーのリストを提供します。

• Username

• SASL/PLAIN 認証のユーザー名を入力します。詳細は SASL/PLAIN 資格情報の生成 のガイドを参照してください。

• Password

• SASL/PLAIN 認証のパスワードを入力します。詳細は SASL/PLAIN 資格情報の生成 のガイドを参照してください。

• Stream Governance

• Show をクリックして非表示のフィールドを展開します。この部分の設定は、メッセージスキーマのソースとして Confluent Cloud Schema Registry を使用する予定の場合に必要です。詳細は Stream Governance 資格情報の生成 のガイドを参照してください。

  • Stream Governance API URL

  • Stream Governance API（Schema Registry および Stream Catalog API）の URL を入力します。

  • Stream Governance username

  • スキーマレジストリのユーザー名を入力します。この値は Confluent Cloud の Stream Governance API キー名です。

  • Stream Governance password

  • スキーマレジストリのパスワードを入力します。これは Confluent Cloud の Stream Governance API キーシークレットです。

4

Connect をクリックします。

SASL/PLAIN 資格情報の生成

以下の手順で SASL/PLAIN 資格情報を生成します：

1

Confluent Cloud (opens new window) アカウントにサインインします。

2

左側のパネルで Environments を選択し、特定の Kafka クラスターをクリックしてその概要ページを開きます。

Select a cluster

3

左側のパネルから Cluster settings を選択します。

4

Bootstrap servers エントリを見つけます。これは、Kafka クライアントを構成するために必要なホストとポートの組み合わせのリストを提供します。通常は pkd-lzurc.us-west1.gcp.confluent.cloud:9091 のような URL のリストで、各エントリはホストとポートで構成されています。これが Seed brokers の値です。

Find the Bootstrap servers/Seed brokers entry

5

左側のナビゲーションバーから API Keys を選択します。

Select API keys from the left panel

6

+ Add key をクリックして新しい API キーを作成します。

7

API key と API secret をコピーします。これらの値は、それぞれ Workato 接続設定の Username と Password として使用します。

Stream Governance 資格情報の生成

SCHEMA REGISTRY REQUIREMENTS

Workato requires Stream Governance credentials for use cases that involve using your Confluent Cloud Schema Registry as a source for your message schemas. The following steps are optional if you plan to use a common data model as your schema source.

以下の手順で Stream Governance 資格情報を生成します：

1

Confluent Cloud (opens new window) アカウントにサインインします。

2

左のナビゲーションバーから Environments を選択し、使用する Environment をクリックします。

Open Environments

3

右側のパネルにある Stream Governance API を見つけます。Endpoint の値をコピーします。これは Workato 接続設定の Stream Governance API URL になります。

Copy the Endpoint value

4

Stream Governance API セクションで、Credentials の下にある {N} keys をクリックします。

Click {N} keys

5

+ Add key をクリックして新しい Stream Governance API キーを作成します。

6

API key と API secret をコピーします。これらの値は、それぞれ Workato 接続設定の Stream Governance username と Stream Governance password として使用します。