KafkaConfluentRESTProxyAdapter1C

Адаптер для взаимодействия с 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");
КонецЦикла;
	
Кафка.УдалитьПодисчика(Подписчик);