Адаптер для взаимодействия с kafka через Confluent REST Proxy.
Документация API, на которой основан данный модуль
Быстро посмотреть текст модуля
Основные возможности адаптера:
- Отправка сообщений в топики kafka
- Получение сообщений из топика kafka
- Логирование операций в рамках одного контекста(отправителя или получателя)
- Платформа 8.3.10 и выше.
- "Коннектор: удобный HTTP-клиент для 1С:Предприятие 8" https://github.com/vbondarevsky/Connector
Установите через поставку модуль к себе в конфигурацию(для возможности дальнейшего обновления).
Как отправить сообщение "Hello world!" в топик: "1c.topic":
СоединениеКафка = Кафка.НовоеОписаниеСоединения("http://localhost:8082", "json");
Отправитель = Кафка.НовыйОтправитель(СоединениеКафка);
Кафка.ДобавитьСообщение(Отправитель, "Hello world!", "1c.topic");
Кафка.ОтправитьСообщения(Отправитель); Где залогированы операции:
ТекстЛога = СтрСоединить(Отправитель.ОписаниеСоединения.РезультатСоединения.ИсторияОпераций, Символы.ПС);Как прочитать сообщения из топика: "1с.topic":
СоединениеКафка = Кафка.НовоеОписаниеСоединения("http://localhost:8082", "json");
Подписчик = Кафка.НовыйПодписчик(СоединениеКафка, "ConsumerGroup1C", , Истина, 100);
Кафка.ЗарегистрироватьПодписчика(Подписчик);
Кафка.Подписаться(Подписчик, Объект.topic);
Сообщения = Кафка.ПолучитьСообщения(Подписчик);
Для каждого Сообщение из Сообщения Цикл
ТелоСообщения = Сообщение.Получить("value");
КонецЦикла;
Кафка.УдалитьПодисчика(Подписчик);