Json 到 avro 转换

一篇关于 Json 到 Avro 转换的文章，并添加案例代码。

java
import org.apache.avro.Schema;
import org.apache.avro.generic.GenericData;
import org.apache.avro.generic.GenericRecord;
import org.apache.avro.io.DatumWriter;
import org.apache.avro.io.Encoder;
import org.apache.avro.io.EncoderFactory;
import org.apache.avro.specific.SpecificDatumWriter;
import org.json.JSONObject;
public class JsonToAvroConverter {
    public static void main(String[] args) throws Exception {
        // 定义 Avro Schema
        String avroSchemaJson = "{\"type\":\"record\",\"name\":\"Person\",\"fields\":[{\"name\":\"name\",\"type\":\"string\"},{\"name\":\"age\",\"type\":\"int\"}]}";
        Schema avroSchema = new Schema.Parser().parse(avroSchemaJson);
        // 解析 Json 数据
        String jsonString = "{\"name\":\"John\",\"age\":30}";
        JSONObject jsonObject = new JSONObject(jsonString);
        // 创建 Avro 对象
        GenericRecord avroRecord = new GenericData.Record(avroSchema);
        avroRecord.put("name", jsonObject.getString("name"));
        avroRecord.put("age", jsonObject.getInt("age"));
        // 序列化 Avro 对象
        DatumWriter datumWriter = new SpecificDatumWriter<>(avroSchema);
        Encoder encoder = EncoderFactory.get().binaryEncoder(System.out, null);
        datumWriter.write(avroRecord, encoder);
        encoder.flush();
    }
}