scala - 如何在kafka的消费者端重建html文件？

Question

如果我在 kafka 的生产者端以 Array[Byte] 的形式提供 html 文件，那么如何在 kafka 的消费者端重建 html 文件？

这就是我将 html 文件转换为 Array[Byte] 的方式

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
}