NuclearAPK/Simple-Kafka_Adapter v1.10.2

1.10.2

on GitHub

Выпуск включает изменения 1.10.1 (отдельного релиза для неё не было) и 1.10.2.

Добавлено

• Увеличение числа партиций топика (1.10.1). Новый метод УвеличитьЧислоПартиций доводит число партиций существующего топика до указанного общего значения. Уменьшение Kafka не поддерживает. Описание — в docs/admin.md.
• Приостановка и возобновление чтения (1.10.1). Методы ПриостановитьЧтение и ВозобновитьЧтение работают для всех партиций консьюмера, партиций одного топика или одной партиции. Консьюмер остаётся в группе, ребалансировки нет. Сообщения, скачанные до паузы, приходят после возобновления без потерь и повторов. Описание — в docs/consumer.md.

Исправлено

• Функция при ошибке возвращала значение не своего типа (#95, 1.10.2). Если метод падал, например из-за аргумента не того типа, булев метод возвращал -1, и условие Если Результат Тогда шло по ветке успеха. Теперь возвращается Ложь для булева, -1 для числа, пустая строка для строки, Неопределено для методов с произвольным типом результата, как описано в docs/exceptionHandling.md.
• УстановитьНастройкиТопика и УстановитьНастройкиБрокера сбрасывали не указанные настройки (1.10.1). Теперь используется IncrementalAlterConfigs: меняются только перечисленные параметры, null сбрасывает параметр к умолчанию. Требуется Kafka 2.3+.
• Консьюмер с позициями чтения терял партиции при ребалансировке (1.10.1). Затрагивало УстановитьПозициюЧтения / УстановитьПозицииЧтения, а также cooperative-sticky и group.protocol=consumer (KIP-848).
• Консьюмер с cooperative-sticky не выходил из группы при остановке (1.10.1). ОстановитьКонсьюмера теперь выходит из группы сразу, партиции не простаивают до session.timeout.ms.

Изменено

• Несовместимое изменение (1.10.1): ПолучитьИнформациюОКластере, поле cluster_id. Теперь это настоящий идентификатор кластера, а ID брокера перенесён в новое поле orig_broker_id. Код, который использовал cluster_id как номер брокера, нужно перевести на orig_broker_id.

Подробности — в CHANGELOG.md.

Архив

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

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