使用scala获取kafka主题名

csga3l58  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(160)

我正在开发一个scala应用程序,其中使用了kafka。我想从代码中检索主题名称。我的代码如下:

def getTopic = {
    metadataClient.listTopics().map(x => logger.info(s"topic - $x"))
  }

我从我的主类调用这个方法。在运行时,它不会给出任何错误。但是当我调用这个方法并将结果存储在val中并打印它时。上面写着 Future(<not completed>) . 也不是打印x值。我怎样才能纠正它。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题