> ## Documentation Index
> Fetch the complete documentation index at: https://clickhouse.com/docs/llms.txt
> Use this file to discover all available pages before exploring further.
> Пошаговое руководство по созданию первого Kafka ClickPipe.
# Создание первого Kafka ClickPipe
export const Image = ({img, alt, size = "lg"}) => {
const normalizedSize = ["sm", "md", "lg"].includes(size) ? size : "lg";
return
;
};
> В этом руководстве мы пошагово рассмотрим процесс создания первого Kafka ClickPipe.
Kafka ClickPipes можно развертывать и настраивать вручную через интерфейс ClickPipes, а также программно с помощью [OpenAPI](/docs/ru/integrations/clickpipes/programmatic-access/openapi) и [Terraform](/docs/ru/integrations/clickpipes/programmatic-access/terraform).
В левом меню выберите кнопку `Data Sources` и нажмите "Set up a ClickPipe".
Выберите в списке источник данных Kafka.
Заполните форму: укажите имя для ClickPipe, описание (необязательно), учетные данные и другие сведения о подключении.
Для топиков Avro и Protobuf требуется корректная схема. Подробнее о том, как настроить реестр схем, см. в разделе [Реестры схем](/docs/ru/integrations/clickpipes/kafka/schema-registries).
Настройте обратную частную конечную точку, чтобы ClickPipes могли подключаться к вашему кластеру Kafka через AWS PrivateLink.
Подробнее см. в нашей [документации по AWS PrivateLink](/docs/ru/integrations/clickpipes/networking/aws-privatelink).
Вы можете использовать SSH-туннелирование, если ваш брокер Kafka недоступен из интернета. Вместо прямого подключения ClickPipes устанавливает SSH-соединение с бастион-хостом (сервером в вашей сети, который имеет публичный доступ), а затем перенаправляет через него трафик к вашему брокеру Kafka в частной сети.
1. Включите переключатель "SSH Tunnel".
2. Заполните сведения о SSH-подключении:
* **SSH Host**: имя хоста или IP-адрес вашего бастион-хоста — это общедоступный сервер, который служит шлюзом в вашу частную сеть.
* **SSH Port**: SSH-порт на бастион-хосте (по умолчанию `22`).
* **SSH User**: имя пользователя для аутентификации на бастион-хосте.
3. Чтобы использовать аутентификацию по ключу, нажмите "Revoke and regenerate key pair", чтобы сгенерировать новую пару ключей, и скопируйте созданный открытый ключ на ваш SSH-сервер в `~/.ssh/authorized_keys`.
4. Нажмите "Verify Connection", чтобы проверить подключение.
Убедитесь, что вы добавили [ClickPipes IP addresses](/docs/ru/integrations/clickpipes/networking/static-ips) в правила брандмауэра для SSH-бастиона, чтобы ClickPipes могли установить SSH-туннель.
Выберите топик, и интерфейс отобразит пример документа из этого топика.
На следующем шаге вы можете выбрать, выполнять ли приём данных в новую таблицу ClickHouse или использовать существующую. Следуйте инструкциям на экране, чтобы изменить имя таблицы, схему и настройки. Вверху страницы вы увидите предварительный просмотр изменений в таблице-образце в реальном времени.
Вы также можете настроить дополнительные параметры с помощью доступных элементов управления
ClickPipes создаст отдельного пользователя для записи данных в целевую таблицу. Для этого внутреннего пользователя можно выбрать пользовательскую роль или одну из предопределённых ролей:
* `Full access`: полный доступ к кластеру. Это может быть полезно, если вы используете Materialized View или словарь с целевой таблицей.
* `Only destination table`: только с разрешением `INSERT` для целевой таблицы.
После нажатия на "Create ClickPipe" будет создан и запущен ваш ClickPipe. После этого он появится в разделе Data Sources.