Доступно в редакциях:  EE

Стадия жизненного цикла модуля: Preview
У модуля есть требования для установки

Обзор модуля

Модуль managed-kafka управляет инстансами Kafka в DKP. Он позволяет пользователям конфигурировать Kafka-инстансы в соответствии с их потребностями. Основные возможности:

  • Автоматическое развертывание: Разворачивает инстанс Kafka.
  • Управление конфигурацией: Отдельный ресурс KafkaClass для шаблонизации создания сервиса и валидации пользовательских конфигураций.
  • Управление через класс: Поддерживает sizing-политики, overridable-параметры и CEL-правила валидации.
  • Persistent Storage: Поддерживает работу с persistent volume claim для хранения данных брокера.

Включение модуля

Для включения модуля managed-kafka примените следующий манифест:

apiVersion: deckhouse.io/v1alpha1
kind: ModuleConfig
metadata:
  name: managed-kafka
spec:
  enabled: true
  version: 1

После включения модуля автоматически будет создан кластерный ресурс KafkaClass с именем default.

Быстрый старт

Примеры для быстрог старта можно найти по следующим ссылкам:

Основные ресурсы

Модуль Managed-Kafka предлагает инструменты для двух условных ролей Пользователь и Администратор. Основными объектами модуля являются ресурсы Kafka, KafkaClass.

Условная роль Администратор:

  • управляет cluster-wide ресурсом KafkaClass и создает шаблоны валидаций, правила развертывания и значения по умолчанию для будущих сервисов в DKP.
  • имеет доступ к системному namespace d8-managed-kafka, где развернут Managed-Kafka, к его логам и операционному состоянию.

Условная роль Пользователь:

  • управляет ресурсом Kafka и конфигурирует сервис с учетом ограничений, заданных Администратором в KafkaClass.

Ресурсы Администратора

KafkaClass

Ресурс KafkaClass позволяет ограничивать создание невалидных конфигураций и предопределять значения по умолчанию. Каждый ресурс Kafka обязательно должен быть связан с существующим ресурсом KafkaClass. Перед развертыванием сервиса вся пользовательская конфигурация проверяется на соответствие выбранному KafkaClass. Подробное описание ресурса

Ресурсы Пользователя

Kafka

Ресурс Kafka позволяет создавать инстансы Kafka в пользовательских namespaces Подробное описание ресурса