通過Java API獲取和更新卡夫卡主題配置

Question

我正在編寫一個應用程序，通過Java API對卡夫卡主題執行一堆操作。我可以創建主題並添加分區。我需要獲取主題元數據（如分區，代理）和配置以及更新配置方面的幫助。

僅供參考，我想更新在這裏提供的主題級別配置 - https://kafka.apache.org/documentation#configuration如cleanup.policy，compression.type等

Answer 1

你可以使用下面的代碼打印的主題級CONFIGS。更新配置的用法類似。

字串[] args = { 「--zookeeper」， 「本地主機：2181」， 「--entity型」， 「主題」， 「--entity名」， 「測試」，「 - 描述」};

ConfigCommand.main（args）;

至於獲得的元數據，請參見在https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example尋找一個主題和分區鉛經紀人：

新增：添加配置獲取&更新例如使用AdminUtils：

ZkUtils zkUtils = ZkUtils.apply("localhost:2181/k1", 6000, 10000, JaasUtils.isZkSecurityEnabled()); 

    Properties pp = new Properties(); 
    pp.setProperty("delete.retention.ms", "3000000"); 
    pp.setProperty("file.delete.delay.ms", "40000"); 
    AdminUtils.changeTopicConfig(zkUtils, "test", pp); 
    Properties p = AdminUtils.fetchEntityConfig(zkUtils, ConfigType.Topic(), "test"); 
    System.out.println(p);