Создание кластера Kafka

Чтобы создать кластер:

  1. В главном меню портала перейдите в раздел Ресурсы  Приложения Managed Service for Kafka.
  2. Нажмите на кнопку Заказать кластер или на кнопку  Заказать, если в проекте уже есть созданный кластер.
  3. Заполните поля:

  • Метка * — тег, который присваивается каждому кластеру и помогает ориентироваться в созданных кластерах;
  • Имя кластера * — уникальное имя кластера в рамках проекта. Значение по умолчанию — kafka-<номер>, например, kafka-0001. Последующим кластерам будут присваиваться названия с увеличивающимся порядковым номером;

    1. Длина имени — от 3 до 22 символов.
    2. Может содержать строчные буквы латинского алфавита, цифры и дефис.
  • Описание — описание кластера, заполняется при необходимости;
  • Количество брокеров Kafka*количество серверов Kafka от 1 до 20. При заказе 1 брокера Kafka и ZooKeeper разворачиваются на одном сервере. При заказе больше 1 брокера Kafka автоматически заказывается 3 хоста ZooKeeper;
  • Версия Apache Kafka *;
  • Время хранения информации в топиках, мин — время хранения данных в любом топике в памяти до их сброса на диск, от 30 до 20160 минут;
  • Регион * — регион расположения кластера;
  • Зона доступности * — зона доступности, в которой будет находиться кластер.

Вычислительные ресурсы: 
  • Общие — для публичного облака;
  • Персональные — для частного облака.

Семейство — семейство процессоров:

  • general-purpose — процессоры с частотой 2.2 GHz с конфигурациями b2, с частотой 2.8 GHz с конфигурациями b5, с частотой 3.0 GHz с конфигурациями b3 и процессоры с частотой 4.05 GHz с конфигурациями b4;
  • Advanced — процессоры с частотой 3.0 GHz с конфигурациями a1 и процессоры с частотой 2.8 GHz с конфигурациями a5.

Серия — серия процессоров:

  • Intel Cascade Lake 2.2 GHz;
  • Intel Ice lake 2.8 GHz;
  • Intel Cascade Lake 3.0 GHz;
  • AMD EPYC 9004 series 4.05 GHz.

Конфигурация количество процессоров (CPU) и объём оперативной памяти (RAM). Подробнее см. раздел Конфигурации сервера.

Дополнительный диск — диск, на который устанавливается сервис Kafka:

  • Размер диска, ГБ * объём дополнительного диска в ГБ, от 10 до 2048 ГБ;

  • Тип * — тип диска:
    • Light - IOPS Read: 500 IOPS Write: 300;
    • Basic - IOPS Read: 3000 IOPS Write: 1000;
    • Average cluster 1 - IOPS Read: 10000 IOPS Write: 3000;
    • Average cluster 2 - IOPS Read: 10000 IOPS Write: 3000;
    • Average cluster 3 - IOPS Read: 10000 IOPS Write: 3000;
    • High cluster 1 - IOPS Read: 15000 IOPS Write: 5000;
    • High cluster 2 - IOPS Read: 15000 IOPS Write: 5000;
    • High cluster 3 - IOPS Read: 15000 IOPS Write: 5000.
      IOPS — операции чтения и записи. Чем больше проводится операций чтения, тем меньше операций записи, и наоборот. При выполнении операций расходуется один и тот же дисковый ресурс.

      Примечания

      1. Тип дисков Average cluster и High cluster рекомендуется использовать для серверов, предназначенных для построения кластера на независимых друг от друга дисках. Например, при организации систем типа Primary-Secondary (Master-Slave).

      2. Для оптимальной работы и надёжности хранения данных диски Light и Basic проходят ежедневную проверку и исправление ошибок. В процессе этих проверок могут увеличиваться задержки (latency). Если вам нужна стабильно высокая производительность дисков, выбирайте High cluster. Подробнее см. раздел Задержка и производительность дисков.


  • Удалять вместе с сервером — установите флажок, чтобы при удалении кластера диск автоматически удалился;

  • Подсеть * — подсеть, к которой будет подключен кластер, по умолчанию выбрана сеть default и подсеть default-ru-central1-a;
  • Включить Публичный IP-адрес  — активируйте переключатель, если к кластеру нужен доступ из сети Интернет. К каждому брокеру в кластере будет привязан публичный IP-адрес, который отображается на вкладке Общая информация в столбце External socket;

  • Выбрать существующую группу безопасности — активируйте переключатель, чтобы выбрать существующую группу безопасности и не создавать новую; 
  • Группы безопасности сетевого интерфейса — правила, контролирующие входящий и исходящий трафик сервера.

Важно

При первом заказе кластера не активируйте переключатель Выбрать существующую группу безопасности. Группа безопасности с нужными правилами создаётся автоматически после заказа кластера. Подробнее см. раздел Группы безопасности для кластера Kafka.

Доступ — данные пользователя для авторизации в сервисе Kafka:

  • Имя пользователя * — логин пользователя для авторизации в сервисе Kafka.

    1. Длина имени  от 3 до 22 символов.
    2. Может содержать прописные и строчные буквы латинского алфавита, цифры и символ нижнего подчёркивания.
  • Пароль * — пароль пользователя для авторизации в сервисе Kafka.

    1. Длина пароля от 10 до 15 символов.
    2. Должен содержать прописные и строчные буквы латинского алфавита, цифры.

    Чтобы отобразить пароль, нажмите на кнопку .
    Чтобы скопировать пароль, нажмите на кнопку .
    Чтобы сгенерировать пароль, нажмите на кнопку .

Если нужно задать дополнительные параметры настройки кластера, активируйте переключатель Дополнительные параметры кластера. Напишите первую строку #cloud-config и после неё параметры со значениями или загрузите текстовый файл. Например:

#cloud-config
auto.create.topics.enable=false
default.replication.factor=1
min.insync.replicas=3
num.io.threads=8
num.network.threads=3
num.partitions=1
message.max.bytes=10485880
replica.fetch.max.bytes=10485880
  • default.replication.factorколичество копий данных для топика в кластере:
    • минимум — 1;
    • максимум — равно количеству брокеров, если брокеров меньше или равно 4. Иначе 4;
  • min.insync.replicas — число реплик, которые должны быть синхронизированы:
    • минимум — 1;
    • максимум — равно количеству брокеров, если брокеров больше 3. Иначе 3;
  • num.io.threads — количество запросов из очереди:
    • минимум — 8;
    • максимум — 8, если ЦПУ (Cpu central processor unit, отвечает за обработку информации) меньше или равен 8. Иначе равно количеству ЦПУ;
  • num.network.threads — количество результатов в ответной очереди:
    • минимум 3;
    • максимум 3, если ЦПУ меньше или равно 8. Иначе 6;
  • num.partitions — количество разделов лог-файла на 1 топик в кластере:
    • минимум — 1;
    • максимум — 50;
  • message.max.bytes — максимальный размер сообщения от производителя в МБ: 
    • минимум — 1048588;
    • максимум — 10485880.

      При добавлении данного параметра добавьте параметр replica.fetch.max.bytes с аналогичным значением.

  • replica.fetch.max.bytes — размер буфера межброкерных сообщений в МБ:
    • минимум — 1048588;
    • максимум — 10485880.

      При добавлении данного параметра добавьте параметр message.max.bytes с аналогичным значением.
  • auto.create.topics.enable — автоматическое создание топиков:
    • true — создавать автоматически;
    • false — не создавать автоматически; 
  • unclean.leader.election.enable — следует ли включать реплики, не входящие в набор ISR, в качестве лидера:
    • true — включать;
    • false — не включать.

4. После заполнения полей отобразится стоимость заказа. Нажмите на кнопку Заказать. Кластер разворачивается около 10 минут.

Созданный кластер отобразится на портале:

Чтобы посмотреть подробную информацию о кластере, нажмите на кнопку  в строке с нужным кластером. Откроется страница с информацией о кластере:

  • на вкладке Общая информация отображаются основные параметры кластера, в том числе IP-адреса для подключения к Kafka;
  • на вкладке Сертификаты содержится информация о сертификате для подключения к Kafka с отображением дат начала и окончания действия сертификата. Подробнее см. раздел Настройка сервера для подключения к кластеру Kafka;
  • на вкладке Топики отображаются созданные топики;
  • на вкладке История действий указаны действия пользователя с кластером.

У кластера можно изменить метку, включить/отключить его, изменить вычислительные ресурсы, подключить/отключить публичный IP-адрес, расширить дополнительный диск, увеличить количество брокеров, удалить его и скопировать ID. Подробнее см. раздел Действия с кластером Kafka.

Мы ответили на ваш вопрос?