如果我在kafka的生产者端以数组[byte]的形式输入html文件，那么如何在kafka的消费者端重构html文件？
这就是我如何将html文件转换成数组[字节]

def getByteArray(fileName: String): Array[Byte] =
 {
   val file: File = new File(fileName)
   val fileinputstream: FileInputStream = new FileInputStream(file)
   IOUtils.toByteArray(fileinputstream)
 }

给我建议一个解决方案，通过应用该函数将文件返回到用户端。例如

def byteArrayToFile(data:Array[Byte]):String={
//suggest
}