Есть ли в akka-Kafka (scala framework) функциональность для перечисления всех доступных тем

Question

Я пытаюсь проверить, является ли тема, переданная моему методу "start stream", допустимой / уже существующей темой в Kafka, к которой подключена моя программа.

Я знаю, что в Java есть KafkaConsumer.ListTopics, но я работаю с библиотекой akka-kafka, и кажется, что ConsumerSetting не имеет тот же метод.У меня мог бы быть код, который выполняет сценарий для перечисления тем kafka с помощью команды Kafka-themes --list, но я бы предпочел менее дерзкий способ, чем этот.

Answer 1

Вам нужно создать KafkaConsumer из этого объекта настроек, тогда вы сможете использовать методы API, которые вы упомянули.

Вы не должны подвергать Zookeeper напрямую неаутентифицированным клиентам.

Answer 2

Лучший способ для этого - получить список тем от zookeeper, например:

 import org.apache.zookeeper.ZooKeeper;

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