Автоматическая смена кафки топика раздела

Question

У меня проблема с моим кластером Kafka.У меня есть 3 брокера, поэтому, когда я останавливаю брокера 1 (например), каждый раздел раздела с лидером 1 меняет своего лидера на второго брокера в конфигурации реплики.Так что это хорошее поведение, и оно отлично работает.

Но когда я перезапускаю брокер 1, мне нужно выполнить:

./kafka-preferred-replica-election.sh --zookeeper myHost

, потому что текущий лидер - этодругая реплика.

Итак, мой вопрос: есть ли способ настроить Кафку на автоматическое выполнение?

thx

Answer 1

Я предполагаю, что ваше задание по умолчанию (когда работают все брокеры) сбалансировано, и предпочтительные лидеры распределены равномерно.

Да Кафка может переизбирать предпочтительных лидеров для всех разделов автоматически, когдаброкер перезапущен.Это на самом деле включено по умолчанию, см. auto.leader.rebalance.enable.

После перезапуска брокера Кафке может потребоваться до leader.imbalance.check.interval.seconds, чтобы вызвать переизбрание.По умолчанию это 5 минут.Так что, может быть, вы просто не подождали достаточно долго!

Существует также leader.imbalance.per.broker.percentage, который определяет процент допустимых непривилегированных лидеров.По умолчанию используется значение 10%.

Для получения полной информации об этих настройках см. Раздел конфигурации брокера *1013* на веб-сайте Kafka.