前置条件
我们假定你已熟悉以下内容:- ClickHouse Connector Sink
- Confluent Cloud
ClickHouse 官方 Kafka 连接器与 Confluent Cloud 集成
创建 Topic
在 Confluent Cloud 上创建 topic 非常简单,详细说明请参见此处。重要说明
- Kafka topic 名称必须与 ClickHouse 表名保持一致。如需调整,可使用转换器 (例如
ExtractTopic) 。 - 分区更多并不一定意味着性能更高——更多详情和性能优化建议,请参阅我们即将发布的指南。
准备连接信息
要通过 HTTP(S) 连接到 ClickHouse,你需要以下信息:
你的 ClickHouse Cloud 服务的连接信息可在 ClickHouse Cloud 控制台中查看。
选择一个服务,然后点击 Connect:

curl 命令中。

安装 Connector
按照官方文档中的说明,在 Confluent Cloud 上安装全托管的 ClickHouse Sink Connector。配置 Connector
在配置 ClickHouse Sink Connector 时,您需要提供以下信息:- 您的 ClickHouse server 的 hostname
- 您的 ClickHouse server 的端口 (默认为 8443)
- 您的 ClickHouse server 的用户名和密码
- ClickHouse 中用于写入数据的 database 名称
- Kafka 中用于将数据写入 ClickHouse 的 topic 名称