SpringBoot如何获取Kafka的Topic列表

创建主题
kafka-topics.sh --zookeeper localhost:2181 --create --topic my-topic --replication-factor 3 --partitions 3
查看主题列表
kafka-topics.sh --zookeeper localhost:2181 --list
查看主题状态
kafka-topics.sh --describe  --zookeeper 127.0.0.1:2181 --topic TestTopic 

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

public static void main(String[] args) {
        Properties properties =  new Properties();
        properties.put("bootstrap.servers", "10.0.59.11:9093");
        properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        AdminClient adminClient = AdminClient.create(properties);
        ListTopicsResult result = adminClient.listTopics();
        KafkaFuture<Set<String>> names = result.names();
        try {
            names.get().forEach((k)->{
                System.out.println(k);
            });
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
        adminClient.close();
    }

public abstract class AdminClient implements Admin {
    public AdminClient() {
    }

    public static AdminClient create(Properties props) {
        return (AdminClient)Admin.create(props);
    }

    public static AdminClient create(Map<String, Object> conf) {
        return (AdminClient)Admin.create(conf);
    }
}

static Admin create(Properties props) {
        return KafkaAdminClient.createInternal(new AdminClientConfig(props, true), (TimeoutProcessorFactory)null);
    }

    static Admin create(Map<String, Object> conf) {
        return KafkaAdminClient.createInternal(new AdminClientConfig(conf, true), (TimeoutProcessorFactory)null);
    }

    default void close() {
        this.close(9223372036854775807L, TimeUnit.MILLISECONDS);
    }

    /** @deprecated */
    @Deprecated
    default void close(long duration, TimeUnit unit) {
        this.close(Duration.ofMillis(unit.toMillis(duration)));
    }

    void close(Duration var1);

    default CreateTopicsResult createTopics(Collection<NewTopic> newTopics) {
        return this.createTopics(newTopics, new CreateTopicsOptions());
    }

    CreateTopicsResult createTopics(Collection<NewTopic> var1, CreateTopicsOptions var2);

    default DeleteTopicsResult deleteTopics(Collection<String> topics) {
        return this.deleteTopics(topics, new DeleteTopicsOptions());
    }

    DeleteTopicsResult deleteTopics(Collection<String> var1, DeleteTopicsOptions var2);

    default ListTopicsResult listTopics() {
        return this.listTopics(new ListTopicsOptions());
    }

    ListTopicsResult listTopics(ListTopicsOptions var1);

    default DescribeTopicsResult describeTopics(Collection<String> topicNames) {
        return this.describeTopics(topicNames, new DescribeTopicsOptions());
    }

    DescribeTopicsResult describeTopics(Collection<String> var1, DescribeTopicsOptions var2);

    default DescribeClusterResult describeCluster() {
        return this.describeCluster(new DescribeClusterOptions());
    }

    DescribeClusterResult describeCluster(DescribeClusterOptions var1);

    default DescribeAclsResult describeAcls(AclBindingFilter filter) {
        return this.describeAcls(filter, new DescribeAclsOptions());
    }

    DescribeAclsResult describeAcls(AclBindingFilter var1, DescribeAclsOptions var2);