Convert POJO/Map to AVRO GenericRecord

AvroConverter.java

import org.apache.avro.generic.GenericData;
import org.apache.avro.Schema;
import org.apache.avro.io.DecoderFactory;
import org.apache.avro.io.Decoder;
import org.apache.avro.io.DatumReader;
import org.apache.avro.generic.GenericDatumReader;

public class AvroConverter {
    public static GenericData.Record parseJson(String data, Schema schema) throws IOException {
        Decoder decoder = DecoderFactory.get().jsonDecoder(schema, data);
        
        DatumReader<GenericData.Record> reader = new GenericDatumReader<>(schema);
        return reader.read(null, decoder);
    }
}