Simple Kafka Connector 1C - Версия 1.6.1

🎉 Основные изменения

✨ Добавлена полная поддержка Protocol Buffers (Protobuf)

Теперь компонента поддерживает работу с Protocol Buffers - эффективным бинарным форматом сериализации данных от Google. Добавлены 6 новых методов:

Методы для работы с Protobuf:

СохранитьСхемуProtobuf / PutProtoSchema
- Сохранение .proto схемы для последующего использования
ПреобразоватьВФорматProtobuf / ConvertToProtobufFormat
- Конвертация JSON данных в Protobuf формат
СохранитьФайлProtobuf / SaveProtobufFile
- Сохранение Protobuf данных в файл
ДекодироватьСообщениеProtobuf / DecodeProtobufMessage
- Декодирование Protobuf сообщений в JSON или бинарные данные
ОтправитьСообщениеProtobuf / ProduceProtobuf
- Асинхронная отправка Protobuf сообщений в Kafka
ОтправитьСообщениеProtobufСОжиданиемРезультата / ProduceProtobufWithWaitResult
- Синхронная отправка Protobuf сообщений с ожиданием результата

📖 Документация по работе с Protobuf

✨ Добавлен метод декодирования AVRO

ДекодироватьСообщениеAVRO / DecodeAvroMessage - декодирование AVRO сообщений, полученных из Kafka, в JSON или бинарные данные.

✨ Реализован метод получения параметров

ПолучитьПараметры / GetParameters - получение всех установленных параметров в формате JSON.

Метод возвращает JSON строку со всеми параметрами, установленными через УстановитьПараметр:

{
    "parameters": [
        { "key": "group.id", "value": "testGroup" },
        { "key": "message.max.bytes", "value": "10485760" },
        { "key": "security.protocol", "value": "SASL_SSL" }
    ]
}

📖 Документация по Producer

NuclearAPK/Simple-Kafka_Adapter v1.6.1 on GitHub