I am really confused by how the RecordLookup processor reads in the data. I have two separate processes flows - one gets data from an API endpoint and the other reads a file (see both below). At the end of each of the flows I have a RecordLookup that searches HBase for a match. The transformed flowfiles I send to the RecordLookup processor look exactly the same as you can see below, but RecordLookup cannot parse the fllowfile from the API flow, and throws this error. It can ONLY parse the input from the file ingestion process.
Any ideas what I might be doing wrong here? Any help is greatly appreciated..
AvroSchema used by the ConvertRecord and the RecordLookup processors.