Add command-config option in AdminClient Kafka java

Question

I want to put conf.put("command-config", "client_security.properties"); as apart of configuration in my AdminClient for Kafka java, but its not working.

https://cwiki.apache.org/confluence/display/KAFKA/KIP-377%3A+TopicCommand+to+use+AdminClient

Some help is provided here but not able to implement it

I have tried below:

    public static void main(String[] args) throws ExecutionException, InterruptedException {
    AdminClient client = null;

        Map<String, Object> conf = new HashMap<>();
        conf.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "");
        conf.put(AdminClientConfig.REQUEST_TIMEOUT_MS_CONFIG, "1000");
        client = AdminClient.create(conf);

    ListTopicsResult ltr = client.listTopics();
    KafkaFuture<Set<String>> names = ltr.names();
    System.out.println(names.get());

}

score 0 · Answer 1 · answered Mar 17 '21 at 22:21

0

--command-config is a CLI argument only, not a AdminClient property

You can directly read your property file into a Properties object to accomplish the same thing

answered Mar 17 '21 at 22:21

OneCricketeer

179,855
19
132
245

Thanks...Do you have any working example of that – Mar 18 '21 at 07:41
https://stackoverflow.com/questions/8285595/reading-properties-file-in-java/8285765 – OneCricketeer Mar 18 '21 at 19:15

Add command-config option in AdminClient Kafka java

1 Answers1