Re: Flink issues with Avro GenericRecord serialization

2021-08-31 Thread tarun joshi
This is resolved by the first approach I mentioned. Thanks Team On Mon, 30 Aug 2021 at 12:35, tarun joshi <1985.ta...@gmail.com> wrote: > An update on this , I see that `IndexedRecord` is part of Avro Library. > Please correct me If I am wrong in assuming that the "Pojo's generated by > Avro POJ

Re: Flink issues with Avro GenericRecord serialization

2021-08-30 Thread tarun joshi
An update on this , I see that `IndexedRecord` is part of Avro Library. Please correct me If I am wrong in assuming that the "Pojo's generated by Avro POJO generator must be implementing IndexedRecord interface" It seems either - I should be parsing Stringified Json from AWS Kinesis directly