Skip to main content

前置条件

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

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月10日