我的生产环境中使用的Kafka版本是1.0.0。根据从官方网站获得的信息,似乎Kafka 1.1.0之前的版本不支持大多数参数的动态修改,但是我仍然想知道哪些特定参数是动态修改的。如果无法动态修改我的参数,应使用哪种方法重新启动和修改参数,以最大程度地减少外部服务的影响?
对于Kafka 1.1.0,可以动态更新以下参数。
Broker Config-
http://kafka.apache.org/11/documentation.html#dynamicbrokerconfigs
主题配置-
http://kafka.apache.org/11/documentation.html#topicconfigs
您可以使用alter
命令更改主题配置,如下所示。
> bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name my-topic
--alter --add-config max.message.bytes=128000