Перейти к содержанию

1С: Адаптер Kafka

OpenYellow Платформа Лицензия БСП

Встраиваемая подсистема для организации двустороннего событийного обмена сообщениями между 1С:Предприятие и Apache Kafka. Построена на базе внешнего компонента Simple Kafka Connector 1C.

flowchart LR
    OneC["1С:Предприятие"]
    Adapter["Адаптер Kafka"]
    Kafka["Apache Kafka"]

    OneC -->|"исходящие (публикация)"| Adapter -->|"публикация"| Kafka
    Kafka -->|"опрос (pull)"| Adapter -->|"входящие (обработка)"| OneC

С чего начать

  • Обзор

    Понять идею, архитектуру и поток данных — если вы впервые слышите об адаптере.

    Читать обзор

  • Пользователю

    Установка, настройка, программный API, примеры, мониторинг и эксплуатация.

    Руководство пользователя

  • Разработка проекта

    Для тех, кто развивает саму подсистему: окружение, модули, метаданные, расширение.

    Руководство разработчика

  • Глоссарий

    Термины Apache Kafka для 1С-специалистов.

    К глоссарию

Быстрый старт

Предварительное условие

Доступный кластер Apache Kafka (host:port).

  1. Подключите адаптер к прикладной конфигурации — как расширение или как часть основной конфигурации.
  2. Включите интеграцию — откройте Kafka / Администрирование и нажмите Включить подсистему.
  3. Настройте брокер — создайте элемент и укажите адрес bootstrap-сервера.
  4. Создайте продюсер и/или консьюмер — задайте топик и способ обработки сообщений.
  5. Активируйте регламентное задание — откройте Kafka / Администрирование / Регламентное задание и включите его.
  6. Проверьте обмен — отправьте или получите сообщение и убедитесь, что обмен прошёл успешно.

Что умеет адаптер

  • Автоматическая постановка объектов и наборов записей в очередь при записи
  • Ручная регистрация через UI или программный API
  • Формирование сообщений произвольными обработчиками или через 1С:Конвертация данных 3.1
  • Сериализация и валидация исходящих сообщений на основе XDTO
  • Параллельная отправка через фоновые задания 1С
  • Автоматическая загрузка сообщений из Kafka
  • Обработка произвольными обработчиками или через 1С:Конвертация данных 3.1
  • Десериализация и валидация входящих сообщений на основе XDTO
  • Параллельная обработка через фоновые задания 1С
  • Высокоуровневый API, абстрагирующий работу с Kafka и внешним компонентом
  • Прямой (синхронный) API для нестандартных сценариев
  • Хранение истории обмена и диагностической информации
  • Алерты с уведомлениями в Telegram
  • Выгрузка журнала обмена в Elasticsearch / Logstash / Kibana

Лицензия

Проект распространяется под лицензией Mozilla Public License 2.0 (MPL-2.0). Разрешено использование, модификация и распространение — в том числе в коммерческих проектах. Изменения в файлах под MPL-2.0 должны оставаться открытыми.