メインコンテンツまでスキップ
メインコンテンツまでスキップ

Creating your first Kafka ClickPipe

このガイドでは、最初の Kafka ClickPipe を作成するプロセスを説明します。

データソースに移動​

左側のメニューで Data Sources ボタンを選択し、「Set up a ClickPipe」をクリックします。

Select imports

データソースを選択​

リストから Kafka データソースを選択します。

Select data source type

データソースを設定​

名前、説明 (オプション)、資格情報、およびその他の接続詳細を提供して、ClickPipe のフォームに記入します。

Fill out connection details

スキーマレジストリの設定 (オプション)​

Avro ストリームには有効なスキーマが必要です。スキーマレジストリの設定方法については、Schema registries を参照してください。

リバースプライベートエンドポイントの設定 (オプション)​

ClickPipes が AWS PrivateLink を使用して Kafka クラスターに接続できるように、リバースプライベートエンドポイントを設定します。 詳細については、AWS PrivateLink documentation を参照してください。

トピックを選択​

トピックを選択すると、UI にトピックからのサンプルドキュメントが表示されます。

Set your topic

宛先テーブルを設定​

次のステップでは、新しい ClickHouse テーブルにデータを取り込むか、既存のテーブルを再利用するかを選択できます。画面の指示に従って、テーブル名、スキーマ、および設定を変更します。変更のリアルタイムプレビューを上部のサンプルテーブルで確認できます。

Set table, schema, and settings

提供されたコントロールを使用して高度な設定をカスタマイズすることもできます。

Set advanced controls

権限を設定​

ClickPipes は、宛先テーブルにデータを書き込むための専用ユーザーを作成します。この内部ユーザーに対して、カスタムロールまたは事前定義されたロールのいずれかを使用してロールを選択できます:

  • Full access: クラスターへの完全なアクセスを持ちます。宛先テーブルで Materialized View または Dictionary を使用する場合に便利です。
  • Only destination table: 宛先テーブルに対して INSERT 権限のみを持ちます。
Permissions

セットアップを完了​

「Create ClickPipe」をクリックすると、ClickPipe が作成されて実行されます。これにより、Data Sources セクションに表示されるようになります。

View overview