Set up docs MCPПредварительные требования
Предполагается, что вы знакомы со следующим:
- ClickHouse Connector Sink
- Confluent Cloud
Официальный коннектор Kafka от ClickHouse для Confluent Cloud
Создайте топик
Создать топик в Confluent Cloud довольно просто, а подробные инструкции доступны здесь.
Важные примечания
- Имя Kafka топика должно совпадать с именем таблицы ClickHouse. Это можно изменить с помощью преобразователя (например,
ExtractTopic). - Большее число партиций не всегда означает более высокую производительность — подробности и рекомендации по оптимизации см. в нашем будущем руководстве.
Подготовьте сведения о подключении
Чтобы подключиться к ClickHouse по HTTP(S), вам понадобится следующая информация:
| Параметр(ы) | Описание |
|---|---|
HOST and PORT |
Обычно используется порт 8443 при использовании TLS и 8123 без TLS. |
DATABASE NAME |
По умолчанию есть база данных default; используйте имя базы данных, к которой хотите подключиться. |
USERNAME and PASSWORD |
По умолчанию имя пользователя — default. Используйте имя пользователя, подходящее для вашего сценария использования. |
Сведения о подключении для вашего сервиса ClickHouse Cloud доступны в консоли ClickHouse Cloud. Выберите сервис и нажмите Connect:
Выберите HTTPS. Сведения о подключении будут показаны в примере команды curl.
Если вы используете самоуправляемый ClickHouse, сведения о подключении задаёт ваш администратор ClickHouse.
Установите коннектор
Установите ClickHouse Sink Connector с полным управлением в Confluent Cloud, следуя официальной документации.
Настройте коннектор
При настройке ClickHouse Sink Connector вам потребуется указать следующие данные:
- имя хоста вашего сервера ClickHouse
- порт вашего сервера ClickHouse (по умолчанию — 8443)
- имя пользователя и пароль для вашего сервера ClickHouse
- имя базы данных в ClickHouse, в которую будут записываться данные
- имя топика в Kafka, который будет использоваться для записи данных в ClickHouse
Интерфейс Confluent Cloud поддерживает расширенные параметры конфигурации, позволяющие настраивать интервалы опроса, размеры батча и другие параметры для оптимизации производительности.