!!! THIS PROJECT IS NOT SUPPORTED SINCE IT'S NOW A PART OF AVRO-TOOLS PROJECT
!!! PLEASE USE AVRO-TOOLS PROJECT FOR ALL SUPPORT COMMUNICATION
Converter of JSON object format to AVRO GenericData.Record written in Scala using Play-Json
- unions as you would expect them to be in plain JSON: without avro wrapping
- schema's default values are used if data is missing
- data not present in schema is ignored
BYTESandFIXEDand someLogical Typesare supported through StringParsers- Comprehensive Exceptions: General/Missing Value/Wrong Type. All containing JSON path and description
- Built against scala
2.11,2.12and2.13
libraryDependencies ++= "io.github.agolovenko" %% "json-to-avro-converter" % "1.0.1"import io.github.agolovenko.avro._
import org.apache.avro.Schema
import org.apache.avro.generic.GenericData
import play.api.libs.json.{JsValue, Json}
import StringParsers._
val schema = new Schema.Parser().parse(
"""
|{
| "type": "record",
| "name": "sch_rec2",
| "fields": [
| {
| "name": "field2",
| "type": {
| "type": "array",
| "items": "int"
| },
| "default": [1, 2, 3]
| }
| ]
|}""".stripMargin)
val data = Json.parse("""{"field1": [12, 14]}""")
val parser = new JsonParser(primitiveParsers ++ base64Parsers)
val record: GenericData.Record = parser(data, schema)
val bytes: Array[Byte] = toBytes(record)For more examples check out the tests!