MAN: kafka
Инструкция по развертыванию 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
Это внутренний эндпоинт, который используется для подключения к кластеру Kafka из других сервисов, развернутых внутри той же сети.
Эндпоинт предоставляет доступ к брокерам Kafka по внутренним портам, указанным в конфигурации слушателей.
externalConnect
Это внешний эндпоинт (fqdn), который используется для подключения к кластеру Kafka. Для подключения используеться 9093 порт.
Для подключения используются следующие порты:
* 9092 — внутренний нешифрованный доступ (plain).
* 9093 — внутренний и внешний доступ по TLS, с обязательной TLS-аутентификацией.
---
## 5. Дополнительная информация
Для создания топиков, пользователей и управления ими, а также для интеграции с кластерами Kafka используйте соответствующие сервисы и раздел "Облачные сервисы".
---
