Интеграция 1С:Предприятие и брокера сообщений Apache Kafka

Обновлено: 10.09.2026 · Официальная документация ↗

Архитектура шины данных и проблемы классического обмена

Современные микросервисные архитектуры (Enterprise-уровня) требуют асинхронного, гарантированного обмена сообщениями (Event-Driven Architecture). Классические методы интеграции 1С (REST API, SOAP, файловый обмен) работают синхронно (Point-to-Point) и не выдерживают нагрузок (Highload), приводя к таймаутам и потере данных при недоступности одной из систем. Внедрение брокера Apache Kafka (или RabbitMQ) решает эту проблему. Бизнес-риски отсутствия Kafka: потеря заказов интернет-магазина при перезагрузке серверов 1С, невозможность масштабировать архитектуру.

Подходы к интеграции 1С и Apache Kafka

Метод интеграции	Плюсы	Минусы
Kafka REST Proxy	Не требует внешних компонент. Нативный `HTTPСоединение` в 1С.	Медленно (overhead HTTP). Нет полноценного механизма Consumer (чтение по push).
Внешние компоненты (Native API C++)	Высочайшая скорость. Прямая работа с протоколом Kafka (librdkafka).	Сложность поддержки при обновлении платформы 1С. Зависимости от DLL/SO.
Шлюз (Middleware - Python/Go)	Идеальная архитектура. Микросервис сам читает Kafka и дергает HTTP-сервис 1С.	Требуется команда разработки на другом стеке (Go/Python).

Реализация публикации и подписки (Produce / Consume) в 1С

Сценарий 1: Публикация сообщений (Producer) через Kafka REST Proxy

Confluent REST Proxy позволяет 1С отправлять сообщения в топик Kafka обычным POST-запросом.

 // Отправка JSON документа в топик "orders-topic"
HTTPСоединение = Новый HTTPСоединение("kafka-proxy.corp.local", 8082);
Заголовки = Новый Соответствие;
Заголовки.Вставить("Content-Type", "application/vnd.kafka.json.v2+json");

ТелоСообщения = "{ ""records"": [ { ""value"": { ""OrderID"": ""123"", ""Status"": ""Created"" } } ] }";

HTTPЗапрос = Новый HTTPЗапрос("/topics/orders-topic", Заголовки);
HTTPЗапрос.УстановитьТелоИзСтроки(ТелоСообщения, КодировкаТекста.UTF8);

Ответ = HTTPСоединение.ОтправитьДляОбработки(HTTPЗапрос);

Сценарий 2: Подписка (Consumer) через Внешнюю Компоненту (PinkRabbitMQ/Kafka1C)

Для надежного чтения потока данных из Kafka в 1С используются компоненты, написанные на C++ (Native API). Они реализуют фоновый поток, который вызывает внешнее событие в 1С при поступлении сообщения.

 // В модуле обычного/управляемого приложения или фонового задания
ПодключитьВнешнююКомпоненту("ОбщийМакет.КомпонентаKafka", "Kafka");
Компонента = Новый("AddIn.Kafka.ProducerConsumer");

 // Настройка Consumer
Компонента.Инициализировать("broker1:9092,broker2:9092");
Компонента.ПодписатьсяНаТопик("payments-topic", "my-consumer-group");

 // Получение данных происходит в обработчике ОбработкаВнешнегоСобытия
Процедура ОбработкаВнешнегоСобытия(Источник, Событие, Данные)
    Если Источник = "Kafka" И Событие = "NewMessage" Тогда
        Сообщить("Получен платеж: " + Данные);
    КонецЕсли;
КонецПроцедуры

Типовые ошибки архитекторов

Попытка сделать 1С чистым Consumer'ом: 1С — это монолитная система, её архитектура (rphost) не предназначена для постоянного 'висения' в потоке Kafka (Long Polling). Гораздо надежнее написать микросервис на Go/Java, который будет читать топик Kafka и складывать данные в 1С через пакетный REST API.
Размер сообщений: Kafka оптимизирована для небольших событий (Event Sourcing), до 1 МБ. Попытка переслать через Kafka огромный XML с полным справочником Номенклатуры убьет производительность брокера.

Внедряете 1С:ERP в Enterprise ландшафт?
Хаотичные интеграции 'точка-точка' превращают ИТ-инфраструктуру в спагетти. Архитекторы ITSTM спроектируют и внедрят Enterprise Service Bus (ESB) на базе Apache Kafka или RabbitMQ, обеспечив гарантированную доставку миллионов сообщений в день без потери производительности 1С.

💡 Практика специалистов: Практика ITSTM: Если вы используете внешнюю компоненту Kafka в Linux-среде 1С, обязательно следите за утечками памяти (Memory Leaks) в процессе rphost. Библиотека librdkafka выделяет память вне пула 1С, и платформа не сможет ее очистить (Garbage Collection). Регулярный перезапуск рабочих процессов (настройка кластера) обязателен.

Частые вопросы (FAQ)

В чем отличие интеграции с RabbitMQ и Kafka для 1С?

RabbitMQ — это классическая очередь сообщений (Message Queue) с маршрутизацией (Exchanges). Как только 1С прочитала сообщение, оно удаляется. Kafka — это распределенный лог (Event Streaming). Сообщения хранятся на диске заданное время, и 1С может 'перечитать' историю с определенного смещения (Offset) в случае аварии.

Поддерживает ли 1С протокол AMQP или Kafka нативно?

Нет. Встроенного объекта вроде 'KafkaСоединение' в платформе 1С не существует. Вся интеграция строится либо через прослойку (HTTP API), либо через внешние компоненты (.dll/.so), подключаемые в платформу.

Как обрабатывать миллионы событий из Kafka в 1С без тормозов?

Используйте паттерн 'Micro-batching'. Внешний скрипт читает из Kafka по 1000 сообщений, упаковывает их в один большой JSON массив и отправляет в 1С через HTTP-сервис. 1С обрабатывает массив одной транзакцией, что в десятки раз быстрее построчного чтения.

Где взять внешнюю компоненту для Kafka?

Существуют open-source проекты на GitHub (например, от Infostart community), базирующиеся на библиотеке librdkafka. Однако для Enterprise-применения рекомендуется использовать проверенные коммерческие решения (например, Датареон ESB) или писать middleware-шлюзы.