Hi, I'm new to Apache NiFi and really struggle to apply online previous answers for my question, the Idea is to fetch json from Apache Kafka using a ConsumeKafka processor, it fetches data correctly, now I want to take the attributes from the consumer and load them to a hive database. I tried EvaluationJsonPath to parse the json and log attributes separated, upon inspecting the queue the json appears as from the source and not attributes separated.
Notice how I don't include 'Price/Meter' attribute to test:
This is the queue after the EvaluateJsonPath processor (similar to the source):
Any help dealing with the json to hive situation would be appreciated, thanks.