将 Kafka 与 Java 库结合使用，我想禁用主题的自动创建(如果它尚不存在)。
有些网站说我应该将 auto.create.topics.enable 设置为 false，但这在 Java 中无法识别。
15:11:56.962 [main] WARN o.a.k.c.consumer.ConsumerConfig - The configuration 'auto.create.topics.enable' was supplied but isn't a known config.
目前我将它作为环境变量放在我的 docker-compose 中:
KAFKA_AUTO_CREATE_TOPICS_ENABLE: 'false'
这可行，但我想由用户从 Java 管理它。
这可能吗？
最佳答案
这是经纪人级别的配置。您不能让用户从 java 客户端程序管理它。
由于auto.create.topics.enable属性是只读的broker配置，需要重新启动kafka服务。因此无法从客户端处理它。
您可以在此处使用动态更新模式读取配置:https://kafka.apache.org/documentation/#brokerconfigs
关于java - 卡夫卡 : disable create topic from Java，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/54946384/