Ensure correct GenericData is used

This was missed during a previous refactor
confluentinc · Feb 23, 2024 · aed3b7d · aed3b7d
1 parent b5d8489
commit aed3b7d
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...erializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaAvroDeserializer.java b/...erializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaAvroDeserializer.java
@@ -494,8 +494,10 @@ Object read(AvroSchema writerAvroSchema, AvroSchema readerAvroSchema) {
         DatumReader<?> reader;
         if (!migrations.isEmpty()) {
           // if migration is required, then initially use GenericDatumReader
-          reader = new GenericDatumReader<>(
-              writerSchema, writerSchema, AvroSchemaUtils.getGenericData());
+          reader = new GenericDatumReader<>(writerSchema, writerSchema,
+              avroUseLogicalTypeConverters
+                  ? AvroSchemaUtils.getGenericData()
+                  : GenericData.get());
         } else {
           reader = getDatumReader(writerSchema, readerSchema);
         }