java获取kafka topic

pom依赖

    org.apache.kafka
    kafka_2.11

代码 

public static void main(String[] args) throws InterruptedException, ExecutionException {
        Properties pro = new Properties();

//kafka集群多个kafka,获取topic是按顺序获取的，比如第一个192.168.11.2是正常的就只会获取第一个kafka的topic，后面的kafka就不会去获取,如果第一个服务异常才会去获取第二个kafka
        pro.put("bootstrap.servers", "192.168.11.2:9092,192.168.11.3:9092");
        //KafkaUtils.getTopicNames(zkAddress)
        ListTopicsResult result = KafkaAdminClient.create(pro).listTopics();
        KafkaFuture> set = result.names();
        System.out.println(set.get());
    }