pravega/flink-connectors

Support SpecificRecordBase in DeserializerFromSchemaRegistry

Closed this issue · 0 comments

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