通过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);