问题描述： 当使用@AvroSchema自动生成Avro schema时，生成的schema与使用Java POJO生成的schema不一致。这可能导致在使用Avro进行数据序列化和反序列化时出现问题。

解决方法：

1. 使用自定义Avro schema：不使用@AvroSchema注解，而是手动编写Avro schema文件。这样可以确保生成的schema与Java POJO生成的schema一致。

例如，创建一个名为"example.avsc"的Avro schema文件，并定义与Java POJO相匹配的schema：

{
  "type": "record",
  "name": "Example",
  "fields": [
    {"name": "field1", "type": "string"},
    {"name": "field2", "type": "int"}
  ]
}

然后，在代码中使用该schema进行序列化和反序列化操作：

import org.apache.avro.Schema;
import org.apache.avro.generic.GenericDatumReader;
import org.apache.avro.generic.GenericDatumWriter;
import org.apache.avro.generic.GenericRecord;
import org.apache.avro.io.DatumReader;
import org.apache.avro.io.DatumWriter;
import org.apache.avro.io.Decoder;
import org.apache.avro.io.Encoder;
import org.apache.avro.io.JsonDecoder;
import org.apache.avro.io.JsonEncoder;

// 读取Avro schema文件
Schema schema = new Schema.Parser().parse(new File("example.avsc"));

// 创建GenericRecord对象
GenericRecord record = new GenericData.Record(schema);
record.put("field1", "value1");
record.put("field2", 123);

// 序列化
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
DatumWriter datumWriter = new GenericDatumWriter<>(schema);
Encoder encoder = new JsonEncoder(schema, outputStream);
datumWriter.write(record, encoder);
encoder.flush();

// 反序列化
ByteArrayInputStream inputStream = new ByteArrayInputStream(outputStream.toByteArray());
DatumReader datumReader = new GenericDatumReader<>(schema);
Decoder decoder = new JsonDecoder(schema, inputStream);
GenericRecord deserializedRecord = datumReader.read(null, decoder);

// 检查反序列化后的结果
System.out.println(deserializedRecord.get("field1"));
System.out.println(deserializedRecord.get("field2"));

2. 使用其他Avro POJO生成工具：尝试使用其他第三方工具，如Apache Avro Maven插件或其他代码生成工具，来生成Avro POJO和相应的Avro schema。这些工具通常能够生成一致的Avro schema和Java POJO，并提供更多的自定义选项。

例如，可以使用Apache Avro Maven插件来生成Avro POJO和schema： 在pom.xml中添加以下插件配置：

  
    
      org.apache.avro
      avro-maven-plugin
      1.10.2
      
        
          generate-sources
          
            schema
            protocol
            idl-protocol
            idl
            schema
          
          
            ${project.basedir}/src/main/resources/avro
            ${project.build.directory}/generated-sources/avro
          
        
      
    
  

在src/main/resources/avro目录下创建一个名为"example.avsc"的Avro schema文件。

然后运行以下Maven命令：

mvn generate-sources

这将生成Avro POJO和相应的Avro schema文件。

然后可以使用生成的Avro POJO进行序列化和反序列化操作：

import org.apache.avro.Schema;
import org.apache.avro.generic.GenericDatumReader;
import org.apache.avro.generic.GenericDatumWriter;
import org.apache.avro.generic.GenericRecord;
import org.apache.avro.io.DatumReader;
import org.apache.avro.io.DatumWriter;
import org.apache.avro.io.Decoder;
import org.apache.avro.io.Encoder;
import org.apache.avro.io.JsonDecoder;
import org.apache.avro.io.JsonEncoder;

// 读取Avro schema文件