Support Questions

Find answers, ask questions, and share your expertise

InferAvroSchema - JSON flowfile going straight to failure queue

avatar
New Contributor

Hey,

I am trying to automatically infer an arvo schema from a JSON object. Unfortunately I think I'm missing something and I'm not sure what. I am trying to infer the schema automatically as the data feed is still under dev, and there will be changes. I have already setup anther flow using the Evaluate JSON path and replace text processor and don't want to constantly update it.

Have set the "Schema Output Destination" to "flowfile-attribute" and the "Input Content Type" to JSON. In the ConvertJSONToArvo processor I have set the record schema to "${inferred.avro.schema}"

41414-l5mu3.pngThanks for your time

James


vvzvu.png
1 ACCEPTED SOLUTION

avatar
New Contributor

Figured it out, the config above works. Sorry there was an illegal character in my JSON. I wrongly assumed that the JSON object was fine since it worked with the EvaluateJsonPath and not InferArvoSchema

View solution in original post

1 REPLY 1

avatar
New Contributor

Figured it out, the config above works. Sorry there was an illegal character in my JSON. I wrongly assumed that the JSON object was fine since it worked with the EvaluateJsonPath and not InferArvoSchema