> ## Documentation Index
> Fetch the complete documentation index at: https://clickhouse.com/docs/llms.txt
> Use this file to discover all available pages before exploring further.
> はじめての Kafka ClickPipe を作成するための手順を順を追って説明するガイド。
# はじめての Kafka ClickPipe の作成
export const Image = ({img, alt, size = "lg"}) => {
const normalizedSize = ["sm", "md", "lg"].includes(size) ? size : "lg";
return
;
};
> このガイドでは、はじめての Kafka ClickPipe を作成する手順を順を追って説明します。
Kafka ClickPipes は、ClickPipes UI を使用して手動でデプロイおよび管理できるほか、[OpenAPI](/docs/ja/integrations/clickpipes/programmatic-access/openapi) や [Terraform](/docs/ja/integrations/clickpipes/programmatic-access/terraform) を使用してプログラムからデプロイおよび管理することもできます。
左側のメニューで `Data Sources` ボタンを選択し、"Set up a ClickPipe" をクリックします。
一覧からKafkaのデータソースを選択します。
ClickPipe の名前、説明 (任意) 、認証情報、その他の接続情報を入力してフォームを完成させます。
Avro および Protobuf のトピックでは、有効なスキーマが必要です。スキーマレジストリの設定方法について詳しくは、[スキーマレジストリ](/docs/ja/integrations/clickpipes/kafka/schema-registries) を参照してください。
ClickPipes が AWS PrivateLink 経由で Kafka クラスターに接続できるよう、リバース プライベート エンドポイントを設定します。
詳細については、[AWS PrivateLink ドキュメント](/docs/ja/integrations/clickpipes/aws-privatelink)を参照してください。
Kafka ブローカーにパブリックにアクセスできない場合は、SSH トンネリングを使用できます。ClickPipes は直接接続する代わりに、踏み台サーバー (ネットワーク内にあり、パブリックにアクセス可能なサーバー) への SSH 接続を確立し、その接続を経由してプライベートネットワーク上の Kafka ブローカーにトラフィックを転送します。
1. "SSH Tunnel" トグルを有効にします。
2. SSH 接続の詳細を入力します。
* **SSH Host**: 踏み台サーバーのホスト名または IP アドレス。プライベートネットワークへのゲートウェイとして機能する、パブリックにアクセス可能なサーバーです。
* **SSH Port**: 踏み台サーバーの SSH ポート (デフォルトは `22`) 。
* **SSH User**: 踏み台サーバーで認証に使用するユーザー名。
3. 鍵ベース認証を使用するには、"Revoke and regenerate key pair" をクリックして新しい鍵ペアを生成し、生成された公開鍵を SSH サーバーの `~/.ssh/authorized_keys` にコピーします。
4. "Verify Connection" をクリックして接続を確認します。
ClickPipes が SSH トンネルを確立できるように、SSH 踏み台サーバーのファイアウォールルールで [ClickPipes IP addresses](/docs/ja/integrations/clickpipes/home#list-of-static-ips) を許可してください。
トピックを選択すると、UI にそのトピックのサンプルドキュメントが表示されます。
次のステップでは、データを新しい ClickHouse テーブルに取り込むか、既存のテーブルを再利用するかを選択できます。画面の案内に従って、テーブル名、スキーマ、設定を変更してください。上部のサンプルテーブルで、変更内容をリアルタイムでプレビューできます。
用意されているコントロールを使用して、詳細設定をカスタマイズすることもできます。
ClickPipes は、宛先テーブルにデータを書き込むための専用ユーザーを作成します。この内部ユーザーには、カスタムロールまたは事前定義済みロールのいずれかを選択できます。
* `Full access`: クラスターへのフルアクセス権を付与します。宛先テーブルで materialized view や Dictionary を使用する場合に便利です。
* `Only destination table`: 宛先テーブルに対する `INSERT` 権限のみを付与します。
"Create ClickPipe" をクリックすると、ClickPipe が作成されて起動します。作成後は、Data Sources セクションに表示されます。