Создание новых потоков событий#

Сценарий для пользователя с ролью Access manager (Администратор доступа).

Предусловия#

Не требуются.

Последовательность выполнения#

На сервере, где расположены брокеры Apache Kafka, выполнить команду:

./bin/kafka-topics.sh --bootstrap-server 'hostname -f':<порт> --create --command-config ~/ssl_adm.properties --topic <наименование потока> --partitions <количество партиций> --replication-factor <фактор репликации> --config retention.ms=<сколько хранить события> --config retention.bytes=<максимальный размер партиции> --config max.message.bytes=<максимальный размер сообщения>

, где:

  • topic — наименование потока событий в соответствии с правилом наименования: <индентификатор системы-поставщика>.<тип события>EVENT.V<версия формата события>

    Например: AS1.ENTITYCHANGEDEVENT.V1

  • partitions — количество партиций, рассчитывается исходя из предполагаемой нагрузки;

  • replication-factor — фактор репликации, отвечает за отказоустойчивость потока, обычно указывается как количество брокеров Apache Kafka — 1;

  • config retention.ms — время хранения событий в потоке в миллисекундах, по истечении данного времени события будут удалены;

  • config retention.bytes — максимальный размер партиции в байтах, при его превышении самые старые события будут удалены;

  • config max.message.bytes — максимальный размер пачки в потоке в байтах. При попытке публикации события, превышающего данное значение, будет выдана ошибка.

Правила эксплуатации#

Не требуется.

Результат#

Новые потоки событий созданы.