> ## Documentation Index
> Fetch the complete documentation index at: https://private-7c7dfe99-home-button.mintlify.site/llms.txt
> Use this file to discover all available pages before exploring further.

> 创建你的首个 Kafka ClickPipe 的分步指南。

# 创建你的首个 Kafka ClickPipe

export const Image = ({img, alt, size}) => {
  return <Frame>
      <img src={img} alt={alt} />
    </Frame>;
};

> 本指南将介绍如何创建你的首个 Kafka ClickPipe。

Kafka ClickPipes 既可以通过 ClickPipes UI 手动部署和管理，也可以通过 [OpenAPI](/zh/integrations/clickpipes/programmatic-access/openapi) 和 [Terraform](/zh/integrations/clickpipes/programmatic-access/terraform) 以编程方式进行部署和管理。

<Steps>
  <Step>
    ## 前往数据源

    在左侧菜单中选择 `Data Sources` 按钮，然后点击 "Set up a ClickPipe"。

    <Image img="https://mintcdn.com/private-7c7dfe99-home-button/St1M90JquFFJKAOf/images/integrations/data-ingestion/clickpipes/cp_step0.png?fit=max&auto=format&n=St1M90JquFFJKAOf&q=85&s=5643c9f1e8db141707ab499d4fa79bde" alt="选择导入项" size="md" width="2606" height="790" data-path="images/integrations/data-ingestion/clickpipes/cp_step0.png" />
  </Step>

  <Step>
    ## 选择数据源

    从列表中选择你的 Kafka 数据源。

    <Image img="https://mintcdn.com/private-7c7dfe99-home-button/St1M90JquFFJKAOf/images/integrations/data-ingestion/clickpipes/cp_step1.png?fit=max&auto=format&n=St1M90JquFFJKAOf&q=85&s=2f9eabcb3f54c0a308450eb0b006ca68" alt="选择数据源类型" size="md" width="2600" height="1890" data-path="images/integrations/data-ingestion/clickpipes/cp_step1.png" />
  </Step>

  <Step>
    ## 配置数据源

    填写表单，为 ClickPipe 填写名称、描述 (可选) 、凭证以及其他连接信息。

    <Image img="https://mintcdn.com/private-7c7dfe99-home-button/St1M90JquFFJKAOf/images/integrations/data-ingestion/clickpipes/cp_step2.png?fit=max&auto=format&n=St1M90JquFFJKAOf&q=85&s=8b271287844343c09ff7cf3f22109bf7" alt="填写连接信息" size="md" width="1896" height="1370" data-path="images/integrations/data-ingestion/clickpipes/cp_step2.png" />
  </Step>

  <Step>
    ## 配置 Schema Registry (可选)

    对于 Avro 和 Protobuf topic，需要提供有效的 schema。有关如何配置 Schema Registry 的更多信息，请参阅 [Schema registries](/zh/integrations/clickpipes/kafka/schema-registries)。
  </Step>

  <Step>
    ## 配置反向专用终结点 (可选)

    配置反向专用终结点，使 ClickPipes 能够通过 AWS PrivateLink 连接到您的 Kafka 集群。
    如需了解更多信息，请参阅我们的 [AWS PrivateLink 文档](/zh/integrations/clickpipes/aws-privatelink)。
  </Step>

  <Step>
    ## 配置 SSH 隧道 (可选)

    如果你的 Kafka broker 无法通过公网访问，可以使用 SSH 隧道。ClickPipes 不会直接连接到 Kafka broker，而是先与堡垒机 (你网络中可通过公网访问的服务器) 建立 SSH 连接，再通过该堡垒机将流量转发到私有网络中的 Kafka broker。

    1. 打开“SSH Tunnel”开关。
    2. 填写 SSH 连接信息：
       * **SSH Host**：堡垒机的主机名或 IP 地址，即可通过公网访问、作为私有网络入口网关的服务器。
       * **SSH Port**：堡垒机上的 SSH 端口 (默认 `22`) 。
       * **SSH User**：用于在堡垒机上进行身份验证的用户名。

    <Image img="https://mintcdn.com/private-7c7dfe99-home-button/St1M90JquFFJKAOf/images/integrations/data-ingestion/clickpipes/cp_ssh_tunnel.png?fit=max&auto=format&n=St1M90JquFFJKAOf&q=85&s=933eabe56fd6cfaa9f23176c2a70204b" alt="SSH 隧道配置" size="md" width="1810" height="1510" data-path="images/integrations/data-ingestion/clickpipes/cp_ssh_tunnel.png" />

    3. 若要使用基于密钥的身份验证，请点击“Revoke and regenerate key pair”生成新的密钥对，并将生成的公钥复制到 SSH 服务器上的 `~/.ssh/authorized_keys` 中。
    4. 点击“Verify Connection”验证连接。

    <Note>
      请确保在 SSH 堡垒机的防火墙规则中将 [ClickPipes IP addresses](/zh/integrations/clickpipes/home#list-of-static-ips) 加入白名单，以便 ClickPipes 能够建立 SSH 隧道。
    </Note>
  </Step>

  <Step>
    ## 选择你的 topic

    选择 topic 后，UI 将显示该 topic 中的一个示例文档。

    <Image img="https://mintcdn.com/private-7c7dfe99-home-button/St1M90JquFFJKAOf/images/integrations/data-ingestion/clickpipes/cp_step3.png?fit=max&auto=format&n=St1M90JquFFJKAOf&q=85&s=e1dddbd3b49915cd6623a07050b69fb4" alt="设置 topic" size="md" width="2380" height="1956" data-path="images/integrations/data-ingestion/clickpipes/cp_step3.png" />
  </Step>

  <Step>
    ## 配置目标端表

    在下一步中，您可以选择将数据摄取到新的 ClickHouse 表中，或使用现有表。按照界面上的说明修改表名、schema 和设置。您可以在顶部的样本表中实时预览这些更改。

    <Image img="https://mintcdn.com/private-7c7dfe99-home-button/St1M90JquFFJKAOf/images/integrations/data-ingestion/clickpipes/cp_step4a.png?fit=max&auto=format&n=St1M90JquFFJKAOf&q=85&s=f5fcb946b627db3b0e138d7d4aaa63f4" alt="设置表、schema 和设置" size="md" width="2734" height="1328" data-path="images/integrations/data-ingestion/clickpipes/cp_step4a.png" />

    您还可以使用提供的控件自定义高级设置

    <Image img="https://mintcdn.com/private-7c7dfe99-home-button/St1M90JquFFJKAOf/images/integrations/data-ingestion/clickpipes/cp_table_settings.png?fit=max&auto=format&n=St1M90JquFFJKAOf&q=85&s=177fd946462f233f16aa4603a9a81c3c" alt="设置高级设置控件" size="md" width="1592" height="338" data-path="images/integrations/data-ingestion/clickpipes/cp_table_settings.png" />
  </Step>

  <Step>
    ## 配置权限

    ClickPipes 会创建一个专用用户，用于将数据写入目标表。你可以为该内部用户选择一个角色，可使用自定义角色或某个预定义角色：

    * `Full access`：对集群拥有完全访问权限。如果你在目标表上使用 materialized view 或字典，这可能会很有帮助。
    * `Only destination table`：仅拥有对目标表的 `INSERT` 权限。

    <Image img="https://mintcdn.com/private-7c7dfe99-home-button/St1M90JquFFJKAOf/images/integrations/data-ingestion/clickpipes/cp_step5.png?fit=max&auto=format&n=St1M90JquFFJKAOf&q=85&s=370d3697f027a058f5d8b84cdab78368" alt="权限" size="md" width="2736" height="1318" data-path="images/integrations/data-ingestion/clickpipes/cp_step5.png" />
  </Step>

  <Step>
    ## 完成设置

    点击 "Create ClickPipe" 后，系统将创建并运行您的 ClickPipe。随后，它会显示在“数据源”部分。

    <Image img="https://mintcdn.com/private-7c7dfe99-home-button/St1M90JquFFJKAOf/images/integrations/data-ingestion/clickpipes/cp_overview.png?fit=max&auto=format&n=St1M90JquFFJKAOf&q=85&s=17c26fe93ac7a44939b906e6aefe470f" alt="查看概览" size="md" width="3436" height="1076" data-path="images/integrations/data-ingestion/clickpipes/cp_overview.png" />
  </Step>
</Steps>
