[Improve] update kafka avro e2e

liunaijie · Dec 27, 2023 · da7eec5 · da7eec5
1 parent 04ed0db
commit da7eec5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...tunnel-format-avro/src/main/java/org/apache/seatunnel/format/avro/AvroToRowConverter.java b/...tunnel-format-avro/src/main/java/org/apache/seatunnel/format/avro/AvroToRowConverter.java
@@ -28,9 +28,9 @@
 import org.apache.avro.Conversions;
 import org.apache.avro.Schema;
 import org.apache.avro.data.TimeConversions;
-import org.apache.avro.generic.GenericDatumReader;
 import org.apache.avro.generic.GenericRecord;
 import org.apache.avro.io.DatumReader;
+import org.apache.avro.specific.SpecificDatumReader;
 
 import java.io.Serializable;
 import java.lang.reflect.Array;
@@ -55,7 +55,7 @@ public DatumReader<GenericRecord> getReader() {
     }
 
     private DatumReader<GenericRecord> createReader() {
-        GenericDatumReader<GenericRecord> datumReader = new GenericDatumReader<>(schema, schema);
+        SpecificDatumReader<GenericRecord> datumReader = new SpecificDatumReader<>(schema);
         datumReader.getData().addLogicalTypeConversion(new Conversions.DecimalConversion());
         datumReader.getData().addLogicalTypeConversion(new TimeConversions.DateConversion());
         datumReader