Resource nubes_kafka · v2.0.0 · Service ID: 116 · Service Name: ApacheKafka¶
Manual · Create params · Modify params · Output params · Operations · Example
Сервис ApacheKafka (nubes_kafka). См. Create params для списка параметров.
Справка (MAN)
Инструкция по развертыванию 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-аутентификацией.