Skip to main content
Estuary может подключаться к ClickHouse через Kafka ClickPipe. Эта интеграция избавляет от необходимости поддерживать собственную экосистему Kafka. Вместо этого Estuary отправляет новые данные в виде сообщений Kafka. Вы можете настроить Kafka ClickPipe на использование сведений о брокере и реестре схем Estuary для получения этих сообщений. В качестве альтернативы см. прямую интеграцию Estuary с ClickHouse.

​
Руководство по настройке

Предварительные требования Вам потребуется:
  • Аккаунт Estuary
  • Один или несколько capture в Estuary, получающих данные из нужных источников
  • Аккаунт ClickHouse Cloud с разрешениями на работу с ClickPipe
1

Создайте materialization в Estuary

Чтобы передавать данные из исходных collection в Estuary в ClickHouse, сначала необходимо создать materialization.
  1. На панели мониторинга Estuary перейдите на страницу Destinations.
  2. Нажмите + New Materialization.
  3. Выберите коннектор ClickHouse Kafka API.
  4. Заполните сведения в разделах Materialization, Endpoint и Source Collections:
    • Сведения о materialization: укажите уникальное имя materialization и выберите data plane (облачного провайдера и регион).
    • Конфигурация конечной точки: укажите защищённый Auth Token.
    • Исходные collection: свяжите существующий capture или выберите collection данных, которые будут доступны в ClickHouse.
  5. Нажмите Next, а затем Save and Publish.
  6. На странице сведений о materialization запишите полное имя materialization для ClickHouse. Оно будет выглядеть примерно так: your-tenant/your-unique-name/dekaf-clickhouse.
Estuary начнёт передавать выбранные collection в режиме стриминга в виде сообщений Kafka. ClickHouse сможет обращаться к этим данным через Kafka ClickPipe, используя сведения о брокере Estuary и указанный вами токен аутентификации.
2

Введите сведения о подключении Kafka

Настройте новый Kafka ClickPipe в ClickHouse и укажите сведения о подключении:
  1. На панели мониторинга ClickHouse Cloud выберите Источники данных.
  2. Создайте новый ClickPipe.
  3. Выберите Apache Kafka в качестве источника данных.
  4. Введите сведения о подключении Kafka, используя информацию о брокере и registry Estuary:
    • Укажите имя для ClickPipe.
    • В качестве брокера укажите: dekaf.estuary-data.com:9092.
    • Оставьте значение аутентификации по умолчанию: SASL/PLAIN.
    • В поле пользователя укажите полное имя materialization из Estuary (например, your-tenant/your-unique-name/dekaf-clickhouse).
    • В поле пароля укажите токен аутентификации, заданный для materialization.
  5. Включите параметр реестра схем:
    • В качестве URL схемы укажите: https://dekaf.estuary-data.com.
    • Ключ схемы совпадает с именем пользователя брокера (именем materialization).
    • Секрет совпадает с паролем брокера (вашим токеном аутентификации).
3

Настройте входящие данные

  1. Выберите один из Kafka топиков (одну из collection данных в Estuary).
  2. Выберите смещение.
  3. ClickHouse обнаружит сообщения топика. Затем перейдите в раздел Parse information, чтобы настроить сведения о таблице.
  4. Выберите создание новой таблицы или загрузку данных в соответствующую существующую таблицу.
  5. Сопоставьте исходные поля со столбцами таблицы, указав имя столбца, тип и допустимость значения NULL.
  6. В заключительном разделе Details and settings можно выбрать разрешения для выделенного пользователя базы данных.
Когда конфигурация будет готова, создайте ClickPipe.ClickHouse подготовит новый источник данных и начнёт получать сообщения из Estuary. Создайте столько ClickPipes, сколько потребуется для стриминга всех нужных collection данных.

​
Дополнительные ресурсы

Подробнее о настройке интеграции ClickPipe с Estuary см. в документации Estuary:
Последнее изменение 14 августа 2026 г.