bvaradar opened a new pull request #763: [WIP] Temporary PR : Use customized KafkaAvroDecoder to handle input batch containing records with older schema version URL: https://github.com/apache/incubator-hudi/pull/763 Note this is a temporary PR till Minh submits the actual PR. KafkaAvroDecoder does not guarantee that it will return generic records deserialized with latest schema. This causes deserialization errors during writing time when input batch has records conforming to old schema versions and Hudi tries to deserialize the bytes with latest schema. Hence, this class which would use SchemaProvider to create GenericRecords with latest schema from schema provider.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
