kafka代理配置动态变化

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相关的配置有两种：broker configs and per-topic configs.

由于每个主题的配置由 Zookeeper 集群管理，您可以使用 kafka-topics.sh 即时更改它们。

然而，

controlled.shutdown.enable 是一个 broker 配置，它只能通过 server.properties 文件设置，并且需要在更改时重新启动 broker。

Kafka JIRA 中也讨论了这个问题： [KAFKA-1229] Reload broker config without a restart

Answer 2

您现在可以从 1.1 开始：Dynamic Broker Config

在你的情况下，类似于：

> bin/kafka-configs.sh --bootstrap-server localhost:9092 \ 
--entity-type brokers --entity-name 0 --alter \ 
--add-config controlled.shutdown.enable=true

kafka代理配置动态变化

kafka broker config change dynamically

apache-zookeeper

apache-kafka