Изменение конфигурации kafka broker динамически

Question

Я использую kafka_2.9.2-0.8.1.1 с zookeeper 3.4.6.

Есть ли способ изменить настройки конфигурации брокера динамически? В частности, я хочу изменить controlled.shutdown.enable

bin/kafka-topics.sh --zookeeper zookeeper01.mysite.com --config controlled.shutdown.enable=true --alter

, но я получаю ошибку

Missing required argument "[topic]"

Answer 1

Нет, вы не можете изменить брокера конфиги динамически.

Существует два вида конфигураций, связанных с брокерами: broker configs и per-topic configs.

Так как конфигурации для каждой темы управляются кластером Zookeeper, вы можете изменить их с помощью kafka-topics.sh на лету.

controlled.shutdown.enable является, однако, брокер конфигурации, который может быть установлен только вверх server.properties файла и требует брокера перезапутить, когда необходимо изменить.

Этот вопрос также обсуждался в Кафки JIRA: [KAFKA-1229] Reload broker config without a restart