Rol*_*our 6 java apache-kafka kafka-topic
将 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.enableproperty是只读的broker配置，需要重启kafka服务。因此不可能从客户端处理它。
您可以使用动态更新模式在此处阅读配置：https://kafka.apache.org/documentation/#brokerconfigs
| 归档时间： |
|
| 查看次数： |
15101 次 |
| 最近记录： |