Публичное пространство
SetRetail10 ◾️ Модуль передачи событий в Apache Kafka
- Любовь Чистова
Функциональность предоставляется только при покупке лицензии!
Название лицензии - ПО Set Retail 10 модуль “Передача событий в apache kafka“ Лицензия за кассу.
Описание
Модуль решает проблему дополнительной выгрузки данных, позволяющих оценить показатели качества работы кассиров, отклонения в стандартах работы, возможный фрод, а также влияние дополнительных маркетинговых активностей на объем работы кассиров.
Эти данные можно получить с касс в виде определённых событий, при сочетаемости которых можно будет получить необходимые показатели.
Схема работы
При включении дополнительной лицензии, на кассе появляется возможность выгрузки всех кассовых событий в отдельный топик в Apache Kafka. Сам брокер сообщений Apache Kafka настраивается отдельно. Можно использовать уже имеющийся сервер Kafka, поставляемый например с Set ESB или с Set Loyalty. При совместном использовании Kafka с другими продуктами Set, обязательно должно быть учтено увеличение ресурсов с учётом статистики работы кассовой системы.
В топик отправляются события формируемые кассой в различные моменты работы кассы, такие как добавление товара в чек, авторизация кассира, добавление оплаты, регистрация чека и т.д.
При отсутствии связи с Apache Kafka все события накапливаются в очереди (в базе данных) и будут отправлены при появлении связи.
На сервере Set можно указать фильтр по ограничению отправки только конкретных событий, необходимых и достаточных для формирования требуемой отчётности.
Пример расчета сайзинга
Этот расчет на 1 день хранения данных в Kafka. Срок хранения настраивается на стороне Kafka, т.е. если срок хранения к примеру 7 дней, то итоговый объем нужно умножить на 7.
Размер одного события 300-700 байт. Берём в среднем 600.
На каждую позицию приходится 1-5 события. Возьмём в среднем 3.
На сам чек (оплаты, скидки, и т.д.) приходится ещё 15-20 событий.
При следующих характеристиках торговой сети:
в среднем 10 позиций в чеке,
в среднем 200 чеков с кассы в сутки,
около 4000 касс в сети
Получаем:
(10*3*600+20*600)*200*4000 = 15Гб
*3 для пиковой новогодней нагрузки
Настройка
Топик Kafka
Выгрузка событий производится в топик POS_EVENTS_EXPORT. Топик Kafka создает DevOps CSI через запрос менеджеру проекта.
На сервере
1. На сервере SetRetail/SetCentrum перейдите в раздел Интеграция → Внешние процессинги → кликните 
2. Введите в строке поиска esb → кликните Сервисы отправки событий → установите флажок Set:ESB → кликните .
3. Кликните по процессингу Set:ESB.
4. Выберите магазин или установите флажок Для всей сети → введите коды выгружаемых событий через запятую → кликните .
Если оставить поле пустым - будут выгружаться все события.
В базе данных
На сервере SetCentrum выполните скрипт для настройки адресов брокеров Apache Kafka.
Структура кассовых событий
Структура кассовых событий для Kafka
© 1994-2025, ООО «Кристалл Сервис Интеграция».
Все права защищены..