Support for multiple event types when using GenericRecord

This commit is contained in:
Jose Antonio Iñigo Garrido
2019-06-08 12:40:36 +02:00
committed by Oleg Zhurakousky
parent b1d148f966
commit eb33d7a19b

View File

@@ -135,6 +135,11 @@ public class AvroSchemaServiceManagerImpl implements AvroSchemaServiceManager {
reader = new GenericDatumReader<>(schema);
}
}
else {
if (writerSchema != null) {
reader = new GenericDatumReader(writerSchema);
}
}
}
else {
reader = new ReflectDatumReader(type);