Брокеры сообщений

Брокеры сообщений представляет собой удобный инструмент для отправки/получения данных с сервера PolyAnalyst или на него.

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

Темы Kafka

Настройки данного раздела позволяют вам задать конфигурацию входных и выходных данных через Apache Kafka.

kafka overview

Необходимо заполнить обязательные поля, а именно:

  • Name – название соединения;

  • The file type – расширение файла, в котором содержится сообщение Kafka;

  • bootstrap.servers – адрес и порт сервера.

Следующие настройки опциональны:

  • Topic – название темы Kafka;

  • group.id – идентификатор группы (рекомендуется оставлять поле пустым);

  • partion – номер раздела для работы.

Также необходимо задать параметры аутентификации, например, параметры SASL настраиваются с помощью полей с префиксом sasl, обязательными будут следующие поля:

  • sasl.mechanism;

  • security.protocol;

  • sasl.jaas.config.

Выберите протокол SASL_PLAINTEXT для опции security.protocol:

kafka sasl protocol

Для параметра sasl.mechanism установите значение SCRAM-SHA-256:

kafka sasl mechanism

Для параметра sasl.jaas.config установите значение org.apache.kafka.common.security.scram.ScramLoginModule required username="admin" password="admin-secret";.

Список очередей RabbitMQ

Сервис RabbitMQ можно использовать как еще один источник для импорта/экспорта данных.

rabbitmq settings.rus

Заполните необходимые поля и нажмите кнопку Сохранить изменения.

Список очередей ActiveMQ

Сервис ActiveMQ настраивается похожим образом.

activemq settings.rus