跳转到主要内容

前置条件

我们假定你已熟悉以下内容:

ClickHouse 官方 Kafka 连接器与 Confluent Cloud 集成

创建 Topic

在 Confluent Cloud 上创建 topic 非常简单,详细说明请参见此处

重要说明

  • Kafka topic 名称必须与 ClickHouse 表名保持一致。如需调整,可使用转换器 (例如 ExtractTopic) 。
  • 分区更多并不一定意味着性能更高——更多详情和性能优化建议,请参阅我们即将发布的指南。

准备连接信息

要通过 HTTP(S) 连接到 ClickHouse,你需要以下信息: 你的 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 支持高级配置选项,可用于调整轮询间隔、批次大小和其他参数,以优化性能。

在 Confluent Cloud 上,调整某些设置 (例如 拉取设置轮询设置) 需要通过 Confluent Cloud 提交支持工单。

已知限制

最后修改于 2026年6月12日