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

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

Java

ibeautiful 2022-07-14 17:34:43

將 Kafka 與 Java lib 一起使用，我想禁用主題的自動(dòng)創(chuàng)建（如果它尚不存在）。有些網(wǎng)站說我應(yīng)該把 auto.create.topics.enable 設(shè)置為 false，但這在 Java 中不被識(shí)別。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貢獻(xiàn)1853條經(jīng)驗(yàn) 獲得超9個(gè)贊

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

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

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

反對(duì) 回復(fù) 2022-07-14

慕無忌1623718

TA貢獻(xiàn)1744條經(jīng)驗(yàn) 獲得超4個(gè)贊

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

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

反對(duì) 回復(fù) 2022-07-14