scala - 如何使用 scala 生成 avro ocf 格式（带模式）数据/文件？

Question

我是 Scala 的新手。

我有一个要求，我的数据（在案例类中）需要以 avro OCF（包括模式）格式写入 S3 存储桶。我可以看到在 scala 中生成/序列化 avro 非 ocf（无模式）格式数据的方法，但找不到生成 OCF 格式的方法。

此链接示例显示如何生成非 OCF 格式，但我正在寻找 OCF 格式生成 https://dzone.com/articles/kafka-avro-scala-example

任何帮助/建议将不胜感激。

Answer 1

您需要使用com.sksamuel.avro4s.AvroDataOutputStream该类。