【发布时间】:2020-07-29 17:23:49
【问题描述】:
我正在开发一个 Scala 应用程序。我的项目资源文件夹中有一些文件。这些是 json 文件。我想将它们全部加载为字符串并将它们发送到 kafka 主题。我已经有 kafka 生产者代码,但只是不知道如何处理所有文件并发送它们。我正在使用以下代码
Source.fromResource(path_of_file).mkstring
但是有了这个我只能发送一个我通过的文件,但是我怎样才能编写一个通用代码来加载它们并一个一个地发送它们。这件事我需要在我的黄瓜测试之前做。简而言之,我只想在我的任何场景开始执行之前发送这些文件
【问题讨论】:
-
你看过
java.nio.files包和这个docs.oracle.com/javase/8/docs/api/java/io/File.html 了吗?这可能会满足您的需求。