Support SpecificRecordBase in DeserializerFromSchemaRegistry
Closed this issue · 0 comments
fyang86 commented
Problem description
In DeserializerFromSchemaRegistry
, currently we create an AvroGenericDeserializer
when type class is GenericRecord
or its subclasses, which will ignore the circumstance where type class is SpecificRecordBase
since it is also a subclass of GenericRecord
.
Problem location
DeserializerFromSchemaRegistry
Suggestions for an improvement