Directum RX и Apache Kafka: интеграция оргструктуры в режиме реального времени
Почему Kafka?
Прежде чем выбрать технологию для интеграции, мы оценили несколько вариантов, включая RabbitMQ и другие брокеры сообщений. Однако Apache Kafka выделился по следующим ключевым критериям:
Отказоустойчивость
Kafka хранит каждое сообщение на нескольких узлах кластера, что обеспечивает высокую доступность и защиту от потери данных даже при сбоях оборудования.
Масштабируемость
Система поддерживает «горячее» масштабирование — кластер можно расширять без остановки работы, что особенно важно для крупных предприятий.
Удобство интеграции
Kafka совместим с широким спектром протоколов и легко интегрируется с базами данных, облачными платформами и другими системами.
Безопасность
Поддержка SSL/TLS, аутентификации и детального контроля доступа позволяет соответствовать высоким требованиям информационной безопасности.
Задача: актуализация оргструктуры в Directum RX
Клиент использует систему «Парус» как основной источник данных по организационной структуре. В Directum RX эта структура нужна для корректной работы процессов согласования, распределения задач и формирования отчётности.
Ранее синхронизация выполнялась по расписанию через фоновые задания, что приводило к задержкам и неактуальности данных. Нам нужно было реализовать режим близкий к реальному времени.
Решение: Kafka как шина данных
Мы настроили интеграционную шину следующим образом:
1. Система «Парус» отправляет XML-сообщение об изменении оргструктуры в топик Kafka.
2. В Directum RX запущен фоновый процесс-потребитель (consumer), который слушает этот топик.
3. При поступлении сообщения запускается обработчик, парсит XML и обновляет соответствующие подразделения и сотрудников в Directum RX.
4. Все операции логируются, включая статус обработки (успех/ошибка), что позволяет оперативно выявлять и устранять сбои.
Результат
- Синхронизация оргструктуры стала почти мгновенной — задержка не превышает нескольких секунд.
- Повысилась надёжность — Kafka гарантирует доставку сообщений даже при временных сбоях в Directum RX.
- Упростилось сопровождение — интеграция стала централизованной, а логирование позволило быстро диагностировать проблемы.
Вывод
Apache Kafka — мощный инструмент для построения современных интеграционных решений. Его использование в связке с Directum RX позволяет:
- Обеспечить актуальность данных в режиме реального времени.
- Повысить отказоустойчивость и производительность обмена.
- Гибко масштабировать архитектуру под растущие потребности бизнеса.
Для организаций, которые уже используют Kafka или планируют внедрить единую шину данных, интеграция с Directum RX становится не просто технической возможностью, а стратегическим преимуществом.