Инструкция из личного кабинета Это руководство по сервису из личного кабинета Nubes (ЛК). Текст приведён без изменений, «как есть».
Инструкция по развертыванию Apache Kafka через платформу¶
1. Общая информация¶
Брокер сообщений Apache Kafka — это отказоустойчивая распределённая платформа для обмена сообщениями и потоковой обработки данных в реальном времени. Позволяет надёжно передавать события между сервисами и системами, интегрироваться с внешними решениями и использовать как внутренние, так и защищённые TLS-подключения. Развёртывание полностью автоматизировано платформой.
Доступные операции¶
- create — Создание кластера
- delete — Удаление кластера
- suspend — Остановка кластера
-
resume — Запуск кластера
-
create_topic — Создание топика
- modify_topic — Модификация топика
-
delete_topic — Удаление топика
-
create_user — Создание пользователя
- modify_user — Модификация пользователя
- delete_user — Удаление пользователя
2. Параметры развертывания кластера¶
Ниже перечислены параметры, которые необходимо указать при создании ресурса Kafka:
-
Платформа для развертывания: Платформа для развертывания (среда, в которой будет развернут кластер). Пример:
k8s-3.ext.nubes.ru. -
Количество узлов в сети: Количество узлов (брокеров) в кластере Kafka
-
Квота (megabyte) памяти пода: Квота памяти пода в мегабайтах. Пример:
2048 -
Квота (millicore ) ядра пода: Квота CPU пода в миликорах (1000 mCPU = 1 vCPU). Пример:
1000 -
Размер (gigabyte) диска для базы данных: Размер диска для хранения данных в гигабайтах. Пример:
20 -
Выделяет внешний IP для доступа к master: Флаг, определяющий, нужно ли выделять внешний IP для доступа к master-брокеру. Пример:
trueилиfalse -
Имя ipSpace для публикации внешнего IP Если включен предыдущий параметр, то поле необходимо заполнить. Пример:
internet-no-antiddos-v1
4. Выходные параметры¶
После успешного развертывания ресурса Kafka платформа возвращает ряд параметров. Ключевыми из них являются:
internalConnect (выдаётся только при работе кластера по внутренним адресам) Внутренние эндпоинты для подключения из сервисов, развёрнутых внутри того же Kubernetes-кластера.
internalConnect:
bootstrap:
fqdn: "<serviceName>-kafka-tls-bootstrap.<namespace>.svc.<clusterDomain>"
port: 9093
brokers:
broker-1:
fqdn: "<serviceName>-<serviceName>-pool-0.<serviceName>-kafka-brokers.<namespace>.svc.<clusterDomain>"
port: 9093
externalConnect (выдаётся только при выделении внешнего IP) Внешние эндпоинты, зарегистрированные в DNS.
externalConnect:
bootstrap:
fqdn: "bootstrap.<namespace>.<dnsZone>"
port: 9093
brokers:
broker-1:
fqdn: "broker-1.<namespace>.<dnsZone>"
port: 9093
Заполняется только один из параметров:
- при внешней аллокации (loadbalancer) — externalConnect, internalConnect остаётся пустым;
- при внутреннем режиме — internalConnect, externalConnect остаётся пустым.
Для подключения используются следующие порты:
- 9092 — внутренний нешифрованный доступ (plain).
- 9093 — внутренний и внешний доступ по TLS, с обязательной TLS-аутентификацией.