apache-kafka - 使用 Lenses 时如何更改 Kafka 配置？

Question

我正在使用lensio/box映像在本地运行 Kafka，并且我想禁用主题自动创建 ( auto.create.topics.enable=false)。

似乎没有办法通过网络界面来完成，所以我尝试使用 kafka-configs 工具，但它超时了。

./kafka-configs --bootstrap-server 0.0.0.0:9092 --entity-type brokers --entity-name 0 --alter --add-config auto.create.topics.enable=false

我也尝试过更改/opt/landoop/kafka/etc/kafka/server.properties，但我不知道如何重新启动服务器（/opt/landoop/kafka/bin/kafka-server-stop并且kafka-server-start不起作用）。

更新：所以经纪人 ID 是错误的。现在我有一个不同的错误：

./kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 101 --alter --add-config auto.create.topics.enable=false
Error while executing config command with args '--bootstrap-server localhost:9092 --entity-type brokers --entity-name 101 --alter --add-config auto.create.topics.enable=false'
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.InvalidRequestException: Invalid config value for resource ConfigResource(type=BROKER, name='101'): Cannot update these configs dynamically: Set(auto.create.topics.enable)
        at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
        at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
        at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:104)
        at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:272)
        at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:354)
        at kafka.admin.ConfigCommand$.processCommand(ConfigCommand.scala:302)
        at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:97)
        at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
Caused by: org.apache.kafka.common.errors.InvalidRequestException: Invalid config value for resource ConfigResource(type=BROKER, name='101'): Cannot update these configs dynamically: Set(auto.create.topics.enable)

更新 2：事实证明代理配置不能在运行时更改。所以我不得不server.properties用自定义配置绑定文件。

标签： apache-kafka