1С и Apache kafka

Внешняя компонента для интеграции 1С и Apache kafka удобным способом. Компонента работает под windows и linux. Основная логика написана на Rust, что сильно снижает риск утечек памяти. Есть бесплатная и платная версии.

🎞Видео обзор

Скачать можно по 🔗ссылке

1С и RabbitMQ

Внешняя компонента для интеграции 1С и RabbitMQ удобным способом. Компонента работает под windows и linux. Основная логика написана на Rust, что сильно снижает риск утечек памяти. Есть бесплатная и платная версии.

🎞Видео обзор

Скачать можно 🔗по ссылке

1С и Apache kafka

Новая версия 0.9.1

Добавлена возможность указывать таймаут при получении сообщения. Если в течении этого таймаута не появится сообщение в топике, ожидание в функции
Сообщение = КлиентKafka.ПолучитьСообщение(Канал);
прервется.

Таймаут = 30;//сек. 
КонфигурацияПотребителя = КлиентKafka.КонфигурацияПотребителя(Топик, Теги, Таймаут);
Канал = КлиентKafka.НачатьПолучениеСообщений(КонфигурацияПотребителя);
Сообщение = КлиентKafka.ПолучитьСообщение(Канал);

🎞Первый видео обзор

Скачать можно 🔗по ссылке

1С и RabbitMQ
Новая версия 0.9.6

Добавлена возможность прерывать ожидание нового сообщения из очереди. Так как ожидание в функции КлиентRMQ.СледующееСообщение(Получатель) это блокирующее ожидание, т.к. оно блокирует поток выполнения 1С до момента когда в очереди появится сообщение, а иногда необходимо прервать ожидание, то можно использовать пару методов:
1. КлиентRMQ.ПолучитьСписокПолучателейСообщений() который вернет массив всех получателей и
2. КлиентRMQ.ОстановитьОжиданиеСообщения(Получение). Так же это можно делать интерактивно, через интерфейс обработки КлиентRMQ, там же можно посмотреть как это работает, для программного прерывания ожидания сообщения.

Подробнее 🎞в видео в комментарии

🔗Скачать

🎞Первый видео обзор

1С и Apache kafka

Новая версия 0.9.2

Добавлен метод ДобавитьТопикРазделИСмещение() для явного указания Топика, раздела и смещения, с которого начать чтение. Пример в демо конфигурации, в обработке ОжиданиеИОбработкаСообщенийСРучнымУправлениемСмещением.

  // Указывается явно с какого раздела и с какого смещения начать читать
  // Если не требуется явно указывать номер раздела и смещение, а надо подписаться на топик полность
  // и смещение будет запоминаться на сервере (через вызов КлиентKafka.СохранитьСмещение(Сообщение))
  // то можно не исползовать этот метод, а указать топик в  КлиентKafka.КонфигурацияПотребителя(Топик)
  // Если топик указан через ДобавитьТопикРазделИСмещение, то настройки топика в КлиентKafka.КонфигурацияПотребителя(Топик) будет игнорироваться
  КлиентKafka.ДобавитьТопикРазделИСмещение(КонфигурацияПотребителя, "1CRefs", 0, 2);

🔗Скачать

1С и RabbitMQ
Новая версия 0.9.7
Исправлена ошибка подключения компоненты в linux