Утилита автоматического распределения партиций#

Описание#

Утилита автоматически поддерживает оптимальное распределении топиков кластера. Для этого утилита сохраняет историю изменений топологии кластера: состава брокера и распределения партиций топиков. На основе истории принимается решение о необходимости перераспределения. Новое распределение совпадает с выводом kafka-reassign-partitions.sh -generate.

Топик нуждается в перераспределении, если:

• состав кластера изменился — брокер выпал или был добавлен;

• прошел тайм-аут добавления (удаления) брокера;

• распределение не изменялось вручную с момента последнего изменения состава кластера;

• текущий состав кластера отличается от базового. Базовый состав — состав кластера в момент создания или последнего изменения распределения.

Ожидается, что утилита будет настроена на периодический автоматический запуск средствами ОС.

Режимы работы#

Утилита может работать в следующих режимах:

• --update-history — проверяет топологию кластера и добавляет новое состояние в историю, если требуется;

• --print-history — выводит историю в консоль и в лог;

• --print-topics-to-reassign — находит и выводит в консоль и в лог список топиков, для которых требуется изменить распределение;

• --generate — создает и сохраняет в указанный файл новое распределение для топиков, нуждающихся в перераспределении;

• --reassignment-json-file — файл для сохранения нового распределения;

• --execute — создает и применяет новое распределение для топиков, нуждающихся в перераспределении;

• --auto — полностью автоматический режим работы:

  • обновляет историю;

  • при наличии топиков, нуждающихся в перераспределении, создает и применяет новое распределение.

Параметры#

Параметры для запуска утилиты:

• --bootstrap-server — адрес kafka-сервера для подключения. Обязательный параметр;

• --command-config — property-файл, содержащий конфигурацию, передаваемую AdminClient для подключения к kafka-брокеру (настройки SSL и т.п.).

Конфигурация#