Kotlin:如何将Avro消息解析为Json或数据类

dependencies {
    implementation 'org.apache.avro:avro:1.10.2'
}

val schema = """
    {
        "type": "record",
        "name": "Message",
        "fields": [
            {"name": "id", "type": "int"},
            {"name": "name", "type": "string"}
        ]
    }
""".trimIndent()

val avroData = byteArrayOf(/* Avro消息的二进制数据 */)
val datumReader = GenericDatumReader<GenericRecord>(Schema.Parser().parse(schema))
val decoder = DecoderFactory.get().binaryDecoder(avroData, null)
val record = datumReader.read(null, decoder)

val outputStream = ByteArrayOutputStream()
val jsonEncoder = EncoderFactory.get().jsonEncoder(record.schema, outputStream)
val writer = GenericDatumWriter<GenericRecord>(record.schema)
writer.write(record, jsonEncoder)
jsonEncoder.flush()
val json = outputStream.toString()

plugins {
    id("org.apache.avro") version "1.10.2"
}

avro {
    createSetters = true
    fieldVisibility = "PRIVATE"
    stringType = "String"
    outputCharacterEncoding = "UTF-8"
    source("src/main/avro/*.avsc")
    outputDir = file("src/main/kotlin")
}

val avroData = byteArrayOf(/* Avro消息的二进制数据 */)
val datumReader = SpecificDatumReader<Message>(Message.getClassSchema())
val decoder = DecoderFactory.get().binaryDecoder(avroData, null)
val record = datumReader.read(null, decoder)
val message = Message(record)