Java APIを使用したKafkaトピック設定の取得と更新

Question

Java APIを使用してカフカトピックの操作を一括して実行するアプリケーションを作成しています。トピックを作成してパーティションを追加することができます。トピックのメタデータ（パーティション、ブローカーなど）や設定の取得、設定の更新に関するヘルプが必要です。

参考のために、私はここで提供トピックレベルの設定を更新したい - などcleanup.policyなどhttps://kafka.apache.org/documentation#configuration、compression.typeなど

Answer 1

あなたは、トピック・レベルのコンフィグを印刷するには、以下のコードを使用することができます。更新設定の使用法も同様です。

のString []引数= { "--zookeeper"、 "ローカルホスト：2181"、 "--entity型"、 "項目"、 "--entity名"、 "テスト"、 " --describe "};

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