У существующего топика Kafka число партиций нельзя штатно уменьшить. Обычно создают новый топик с нужным числом партиций и выполняют контролируемую миграцию.
Можно ли в Kafka уменьшить количество партиций?
У существующего топика Kafka число партиций нельзя штатно уменьшить. Обычно создают новый топик с нужным числом партиций и выполняют контролируемую миграцию.
Короткий ответ
Что ответить на собеседовании
Подробный разбор
Ответ с пояснениями
У существующего топика Kafka число партиций нельзя штатно уменьшить. Обычно создают новый топик с нужным числом партиций и выполняют контролируемую миграцию.
Продумайте копирование данных, переключение producers и consumers, сохранение порядка и защиту от повторов. Offset старой партиции нельзя механически перенести в новую раскладку. Увеличение партиций тоже меняет распределение ключей; это отдельное изменение, а не обратимая настройка.
Источник: Документация Apache Kafka.