我正在开发一个scala应用程序,其中使用了kafka。我想从代码中检索主题名称。我的代码如下:
def getTopic = {
metadataClient.listTopics().map(x => logger.info(s"topic - $x"))
}
我从我的主类调用这个方法。在运行时,它不会给出任何错误。但是当我调用这个方法并将结果存储在val中并打印它时。上面写着 Future(<not completed>)
. 也不是打印x值。我怎样才能纠正它。
我正在开发一个scala应用程序,其中使用了kafka。我想从代码中检索主题名称。我的代码如下:
def getTopic = {
metadataClient.listTopics().map(x => logger.info(s"topic - $x"))
}
我从我的主类调用这个方法。在运行时,它不会给出任何错误。但是当我调用这个方法并将结果存储在val中并打印它时。上面写着 Future(<not completed>)
. 也不是打印x值。我怎样才能纠正它。
暂无答案!
目前还没有任何答案,快来回答吧!