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 становится не просто технической возможностью, а стратегическим преимуществом.