Получение и обновление настроек конфигурации Kafka через API Java

Question

Я пишу приложение для выполнения кучи операций по теме kafka через API Java. Я могу создать тему и добавить разделы. Мне нужна помощь в получении метаданных темы (например, разделов, брокеров) и конфигураций и обновлении конфигураций.

Для справки, я хочу, чтобы обновить конфигурацию Темы уровнемеров здесь - https://kafka.apache.org/documentation#configuration таких как cleanup.policy, compression.type и т.д.

Answer 1

Вы можете использовать код, чтобы напечатать конфиги темы уровня. Использование обновления конфигурации аналогично.

String [] агдз = { "--zookeeper", "локальный: 2181", "--entity типа", "темы", "имя---entity", "тест", " --describe "};

ConfigCommand.main (args);

Что касается получения метаданных, пожалуйста, обратитесь к Нахождение Lead брокера для темы и раздела в 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);