如何获取阿帕奇Kafka中的所有话题？

Question

    @RequestMapping(value = "/getTopics",method = RequestMethod.GET)
    @ResponseBody
    public Response getAllTopics() {
        ZkClient zkClient = new ZkClient(ZookeeperProps.zookeeperURL, ZookeeperProps.connectionTimeoutMs,
                ZookeeperProps.sessionTimeoutMs, ZKStringSerializer$.MODULE$);
        Seq<String> topics = ZkUtils.getAllTopics(zkClient);
        scala.collection.Iterator<String> topicIterator = topics.iterator();
        String allTopics = "";
        while(topicIterator.hasNext()) {
            allTopics+=topicIterator.next();
            allTopics+="\n";
        }

        Response response = new Response();
        response.setResponseMessage(allTopics);
        return response;

    }

我是apache kafka的新手。现在，有几天想和动物园管理员一起了解Kafka。我想获取与动物园管理员相关的主题。所以我尝试了以下几点
a：）首先我创建了一个动物园管理员客户端，如下所示：

ZkClient(ZookeeperProps.zookeeperURL, ZookeeperProps.connectionTimeoutMs, ZookeeperProps.sessionTimeoutMs, ZKStringSerializer$.MODULE$);
Seq<String> topics = ZkUtils.getAllTopics(zkClient);

但是使用Java代码执行时主题是空白集。我不明白这里有什么问题。我的动物园管理员道具如下：字符串zkConnect="127.0.0.1:2181"；动物园管理员运行得非常好。
请帮助伙计们。

Answer 1

我更喜欢使用kafka-topics.sh，它是kafka的一个内置shell脚本来获取主题。

Answer 2

您可以使用 kafka AdminClient 。下面的代码片段可能会帮助你：

Properties properties = new Properties();
properties.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");

AdminClient adminClient = AdminClient.create(properties);

ListTopicsOptions listTopicsOptions = new ListTopicsOptions();
listTopicsOptions.listInternal(true);

System.out.println(adminClient.listTopics(listTopicsOptions).names().get());

Answer 3

这很简单。(我的例子是用Java写的，但在Scala中几乎是一样的。)

import java.util.List;

import org.apache.zookeeper.ZooKeeper;

public class KafkaTopicListFetcher {

    public static void main(String[] args) throws Exception {
        ZooKeeper zk = new ZooKeeper("localhost:2181", 10000, null);
        List<String> topics = zk.getChildren("/brokers/topics", false);
        for (String topic : topics) {
            System.out.println(topic);
        }
    }
}

当我有三个主题时的结果:测试、测试2和测试3

test
test2
test3

下图是我为自己的博客帖子画的。当你理解Kafka使用的动物园管理员树的结构时，这将是有帮助的。(这里看起来挺小的。请在新标签中打开图像并放大。)