将 Kafka 与 Java lib 一起使用,我想禁用主题的自动创建(如果它尚不存在)。
有些网站说我应该把 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 管理它。
这可能吗?