pom依赖

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.11</artifactId>
</dependency>

代码 

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<String>> set = result.names();
        System.out.println(set.get());
    }