Использование внешней Apache Kafka

Компонент Apache Kafka используется для передачи данных с серверов управления в бэкенд LCM с помощью подписки на топик брокера сообщений.

Для использования Apache Kafka необходимо выполнить настройки:

Первые три шага выполняются перед установкой продукта.

  1. Установите Apache Kafka, следуя инструкциям в официальной документации.

  2. Создайте топик salt-topic, следуя инструкции в официальной документации.

  3. В конфигурационном файле application.properties задайте параметры:

    1. Укажите URL сервиса Apache Kafka (параметр mp.messaging.incoming.salt-events-kafka.bootstrap.servers).

    2. Задайте имя созданного топика (параметр mp.messaging.incoming.salt-events-kafka.topic).

    3. Опционально. Задайте количество партиций для топика (параметр mp.messaging.incoming.salt-events-kafka.partitions).

  4. После установки продукта задайте имя топика для сервера управления  — в конфигурационном файле salt-master.conf для параметра returner.kafka_custom.topic укажите имя топика salt-topic.