Avro模式解析器通常会忽略byte类型的逻辑类型（如"date"、"time-millis"和"decimal"等），并将其作为原始的byte类型处理。因此，如果您在定义schema时使用了byte类型的逻辑类型，您需要在读取或写入数据时手动处理这些逻辑类型。以下是一个示例：

使用带有byte类型的逻辑类型的schema：

{ "type": "record", "name": "example", "fields": [ { "name": "my_decimal", "type": { "type": "bytes", "logicalType": "decimal", "precision": 4, "scale": 2 } } ] }

读取和写入数据时手动处理逻辑类型：

import org.apache.avro.Conversions.DecimalConversion; import org.apache.avro.LogicalTypes; import org.apache.avro.Schema; import org.apache.avro.generic.GenericData; import org.apache.avro.generic.GenericRecord; import org.apache.avro.generic.GenericData.Record; import org.apache.avro.io.DatumReader; import org.apache.avro.io.DatumWriter; import org.apache.avro.io.Decoder; import org.apache.avro.io.DecoderFactory; import org.apache.avro.io.Encoder; import org.apache.avro.io.EncoderFactory; import org.apache.avro.specific.SpecificDatumReader; import org.apache.avro.specific.SpecificDatumWriter; import org.apache.avro.util.Utf8;

import java.io.ByteArrayOutputStream; import java.io.IOException; import java.math.BigDecimal; import java.nio.ByteBuffer;

public class AvroExample {

// deserialize bytes to record
public static Record deserialize(byte[] bytes, Schema schema) throws IOException {
    DatumReader datumReader = new SpecificDatumReader<>(schema);
    Decoder decoder = DecoderFactory.get().binaryDecoder(bytes, null);
    Record record = datumReader.read(null, decoder);
    return record;
}

// serialize record to bytes
public static byte[] serialize(Record record, Schema schema) throws IOException {
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Datum