跳到主要内容
跳到主要内容

创建您的第一个 Kafka ClickPipe

本指南将指导您完成创建第一个 Kafka ClickPipe 的过程。

导航到数据源

在左侧菜单中点击 Data Sources,然后选择“Set up a ClickPipe”。

Select imports

选择数据源

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

选择数据源类型

配置数据源

在表单中为你的 ClickPipe 填写名称、描述(可选)、凭据以及其他连接信息。

填写连接信息

配置 schema registry(可选)

Avro 流需要一个有效的 schema。有关如何配置 schema registry 的更多信息,请参阅 Schema registries

配置反向私有端点(可选)

配置反向私有端点,以便通过 AWS PrivateLink 允许 ClickPipes 连接到您的 Kafka 集群。 有关更多信息,请参阅我们的 AWS PrivateLink 文档

选择你的主题

选择你的主题后,UI 将会显示该主题中的示例文档。

设置主题

配置目标表

在下一步中,你可以选择将数据摄取到一个新的 ClickHouse 表,或者复用一个已有的表。按照界面中的说明修改表名、schema 和设置。你可以在顶部的示例表中实时预览你的更改。

设置表、schema 和相关配置

你也可以使用提供的控件自定义高级设置。

设置高级选项

配置权限

ClickPipes 会为向目标表写入数据创建一个专用用户。你可以为这个内部用户选择角色,可以使用自定义角色或预定义角色之一:

  • Full access:拥有对集群的完全访问权限。如果你在目标表上使用物化视图或 Dictionary,这个角色会很有用。
  • Only destination table:仅对目标表拥有 INSERT 权限。
权限

完成设置

点击"Create ClickPipe"将创建并运行您的 ClickPipe。创建后,它将显示在数据源部分。

查看概览