NuclearAPK/Simple-Kafka_Adapter v1.10.0

1.10.0

on GitHub

Добавлено

• Чтение топика как очереди (share groups, KIP-932) — экспериментально. Новые методы ИнициализироватьКонсьюмераОчереди, ПодписатьсяНаОчередь, ОтписатьсяОтОчереди, ПрочитатьПакетИзОчереди, ПодтвердитьСообщениеОчереди, ПодтвердитьСообщенияОчереди, ЗафиксироватьПодтвержденияОчереди и ОстановитьКонсьюмераОчереди. Несколько читателей одной группы получают разные записи одной партиции, поэтому обработку можно распараллелить сильнее, чем позволяет число партиций. Каждая запись подтверждается отдельно: accept, release (вернуть в очередь) или reject. Пакет приходит в формате ЧитатьПакетСообщений с полем delivery_count, по нему удобно отклонять запись после нескольких неудачных попыток. Нужен брокер Kafka 4.2 или новее. В librdkafka эта функция пока в статусе Preview, поэтому методы помечены экспериментальными и могут измениться — в продуктивных контурах их использовать рано. Описание, ограничения и примеры — в docs/queues.md.

Изменено

• librdkafka обновлена до 2.16.0 в сборках для Windows и Linux (Linux раньше собирался на 2.12.1). Для сборки из исходников нужен overlay-порт vcpkg-overlay/librdkafka — см. docs/building.md.

Архив

SimpleKafka1C64_1_10_0.zip — компонента для Windows x64 и Linux x64. Linux-библиотека собрана на Ubuntu 24.04 и требует glibc 2.38 или новее. Сборки под RHEL/Rocky 9 (glibc 2.34) в этом выпуске нет.

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