akka-Kafka (scala框架)中是否有列出所有可用主题的功能

Question

我正在尝试检查传递给我的"start stream“方法的主题是否在我的程序所连接的Kafka中是一个有效的/已经存在的主题。

我知道Java有KafkaConsumer.ListTopics，但我正在使用akka-kafka库，似乎ConsumerSetting没有相同的方法。我可以编写代码来执行脚本，使用Kafka-topics - list命令列出kafka主题，但我更喜欢一种更简单的方式。

Answer 1

您必须从该设置对象执行create the KafkaConsumer，然后才能使用您提到的应用编程接口方法。

您不应该将Zookeeper直接暴露给未经身份验证的客户端。

Answer 2

最好的方法是从zookeeper获取主题列表，如下所示：

 import org.apache.zookeeper.ZooKeeper;

 val zk = new ZooKeeper("localhost:2181", 10000, null)
 val topics = zk.getChildren("/brokers/topics", false)