首頁猿問 Kafka：禁用從 Java 創(chuàng)建主題

Kafka：禁用從 Java 創(chuàng)建主題

Java

ibeautiful 2022-07-14 17:34:43

將 Kafka 與 Java lib 一起使用，我想禁用主題的自動創(chuàng)建（如果它尚不存在）。有些網(wǎng)站說我應該把 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.目前我把它作為環(huán)境變量放在我的 docker-compose 中：KAFKA_AUTO_CREATE_TOPICS_ENABLE: 'false'這可行，但我想由用戶從 Java 管理它。這可能嗎？

查看完整描述

2 回答

暮色呼如

TA貢獻1853條經(jīng)驗獲得超9個贊

這是經(jīng)紀人級別的配置。您不能讓用戶從 java 客戶端程序管理它。

由于auto.create.topics.enable屬性是只讀代理配置，需要重啟kafka服務。因此，無法從客戶端處理它。

您可以在此處使用動態(tài)更新模式閱讀配置：https ://kafka.apache.org/documentation/#brokerconfigs

反對回復 2022-07-14

慕無忌1623718

TA貢獻1744條經(jīng)驗獲得超4個贊

Spring 具有spring.cloud.stream.kafka.binder.autoCreateTopics默認為trueBroker 屬性并獨立工作的屬性auto.create.topics.enable。我猜它只有在您的代理配置允許客戶端創(chuàng)建主題時才有效。阻止該權限可能比依賴客戶行為更安全。

https://cloud.spring.io/spring-cloud-stream-binder-kafka/spring-cloud-stream-binder-kafka.html

反對回復 2022-07-14