Hi All, Here is my situation, I have a SpecificRecord for a Schema S and I want to convert it into a GenericRecord of a compatible Schema T (It is an older version of S). I have seen many such examples but all strategies point to serializing the SpecificRecord to either bytes or JSON and deserializing back to the GenericRecord. This seems to be inefficient especially if the records are huge and in a high volume streaming scenario like mine.
I cannot simply cast the SpecificRecord to GenericRecord because of some type incompatibilities like Enums and Instants. I have been looking at the SpecificRecordDatumWriter/Reader sources and try to build a Mapper which just sets the value in the GenericRecord but I cannot write such a mapper without the help of any of the protected and private methods in them. There is a same problem of converting a POJO to GenericRecord as well Appreciate your inputs and recommendations Thanks Kishore