github NuclearAPK/Simple-Kafka_Adapter v1.4.0

latest releases: v1.4.6, v1.4.4, v1.4.2...
12 months ago

Добавлены новые методы для получения сообщений.

ПрочитатьСообщение() - Возвращает истина - если получено очередное сообщение из очереди, ложь - сообщений нет. Обязательно вызываем его перед всеми ниже указанными методами
ПолучитьДанныеСообщения(ВозвращатьДвоичныеДаннные = Ложь) - По умолчанию возвращается строка, если передать Истина - возвращаются двоичные данные сообщения
ПолучитьКлючСообщения() -
ПолучитьЗаголовкиСообщения() - JSON строка содержащая заголовки
ПолучитьТопикСообщения()
ПолучитьИдентификаторБрокераСообщения()
ПолучитьВременнуюМеткуСообщения()
ПолучитьРазделСообщения()
ПолучитьСмещениеСообщения()

Данный подход позволяет повысить отказоустойчивость работы компоненты, а так же не получать данные, которые не нужны.

Добавлена поддержка avro в ограниченном объеме (типы данных, используемые в витринах)

Методы подробно описаны в документации.

Добавлена обработка ошибок

В случае возникновения ошибки, можно попытаться получить описание ошибки, вызвав метод ПолучитьСообщениеОбОшибке

Исправлены выявленные ошибки

Don't miss a new Simple-Kafka_Adapter release

NewReleases is sending notifications on new releases.