[kotlin] avroUtils (/avsc)

object AvroUtils {
    private const val PATH = "/avsc"

    private val parser = Schema.Parser()

    fun define(name: String): Schema {
        return parser.parse(
            AvroUtils.javaClass
                .getResourceAsStream("${PATH}/${name}.avsc")
        )
    }

    fun convert(schema: Schema, json: String): GenericRecord {
        val reader: DatumReader<GenericData.Record> = GenericDatumReader(schema)
        val decoder: Decoder = DecoderFactory().jsonDecoder(schema, json)

        return reader.read(null, decoder)
    }

    fun convert(record: GenericRecord): ByteArray? {
        return toBytes(record)
    }

    @Throws(IOException::class)
    private fun toBytes(genericRecord: GenericRecord): ByteArray? {
        ByteArrayOutputStream().use { outputStream ->
            val writer: DatumWriter<GenericContainer> = GenericDatumWriter(genericRecord.schema)
            writer.setSchema(genericRecord.schema)

            val encoder: BinaryEncoder = EncoderFactory.get().binaryEncoder(outputStream, null)
            writer.write(genericRecord, encoder)
            encoder.flush()
            return outputStream.toByteArray()
        }
    }
}

resources/avsc/data-api.avsc

https://seongtak-yoon.tistory.com/27

[Gradle] 파일 복사, Jar에 파일 포함하기 (task copy)

https://stackoverflow.com/questions/20389255/reading-a-resource-file-from-within-jar

Reading a resource file from within jar

https://toolslick.com/generation/metadata/avro-schema-from-json

Avro Schema From JSON Generator - Tool Slick