NuclearAPK/Simple-Kafka_Adapter v1.9.4

1.9.4

on GitHub

Исправлено

• ПерейтиКВременнойМетке (#91) — метка в миллисекундах обрезалась до int32 и метод падал с bad variant access. Теперь метка принимается Строкой: ПерейтиКВременнойМетке("my-topic", 0, "1788972117044"). Число тоже принимается, но обрезанное до int32 значение отвергается с явной ошибкой. Добавлены проверки имени топика и номера партиции.
• Целочисленные параметры шире int32 не доходили до методов — возвращалось Ложь с текстом bad cast. Добавлен разбор VTYPE_I8, VTYPE_UI8, VTYPE_UI4 и остальных числовых типов.
• СброситьОфсетыГруппыКонсьюмеров (#92) — earliest/latest возвращали Local: No offset stored; теперь границы партиций запрашиваются у брокера. Числовое значение ПозицияСброса трактуется как timestamp в миллисекундах, а не как абсолютный офсет. Параметры Брокер и ИдентификаторГруппы теперь действительно проверяются.
• УдалитьГруппуКонсьюмеров (#90) — аварийное завершение компоненты. Метод переведён на rd_kafka_DeleteGroups, отказ брокера возвращается как Ложь с текстом ошибки.
• ДекодироватьСообщениеProtobuf(..., Ложь) (#89) — возвращалась Строка с искажёнными байтами вместо ДвоичныеДанные.

Полный список изменений: v1.9.3...v1.9.4