前置条件
我们假定你已熟悉以下内容:
- ClickHouse Connector Sink
- Confluent Cloud
ClickHouse 官方 Kafka 连接器与 Confluent Cloud 集成
创建 Topic
在 Confluent Cloud 上创建 topic 非常简单,详细说明请参见此处。
重要说明
- Kafka topic 名称必须与 ClickHouse 表名保持一致。如需调整,可使用转换器 (例如
ExtractTopic) 。 - 分区更多并不一定意味着性能更高——更多详情和性能优化建议,请参阅我们即将发布的指南。
准备连接信息
要通过 HTTP(S) 连接到 ClickHouse,你需要以下信息:
| Parameter(s) | Description |
|---|---|
HOST and PORT |
通常,使用 TLS 时端口为 8443;不使用 TLS 时端口为 8123。 |
DATABASE NAME |
默认情况下,存在一个名为 default 的数据库。请使用你要连接的数据库名称。 |
USERNAME and PASSWORD |
默认情况下,用户名为 default。请根据你的使用场景使用相应的用户名。 |
你的 ClickHouse Cloud 服务的连接信息可在 ClickHouse Cloud 控制台中查看。 选择一个服务,然后点击 Connect:

选择 HTTPS。连接信息会显示在示例 curl 命令中。

如果你使用的是自管理 ClickHouse,则连接信息由你的 ClickHouse 管理员配置。
安装 Connector
按照官方文档中的说明,在 Confluent Cloud 上安装全托管的 ClickHouse Sink Connector。
配置 Connector
在配置 ClickHouse Sink Connector 时,您需要提供以下信息:
- 您的 ClickHouse server 的 hostname
- 您的 ClickHouse server 的端口 (默认为 8443)
- 您的 ClickHouse server 的用户名和密码
- ClickHouse 中用于写入数据的 database 名称
- Kafka 中用于将数据写入 ClickHouse 的 topic 名称
Confluent Cloud UI 支持高级配置选项,可用于调整轮询间隔、批次大小和其他参数,以优化性能。