Hello all, I am using PutElasticSearchRecord. My Reader is JsonTreeReader that validates against an avro schema I've created.
It passes probably since I don't have a good Avro schema for it since my timestamp key is declared as a string. My observation and not sure if working as expected but when I send my output from MergeRecord ( set to 10000 ) max number of records and one of those records has an invalid timestamp "bogusdata" value ES rejects it, rightly so since on ES we have a schema template more granular and is expecting timestamp as type "date". However what I see happening is that my whole "mergedRecord" is rejected and not just that one record. Is that expected? thanks
