Input to my Nifi flow is from CDC-> Kafka
I am using ConsumeKafka processor and in the flowfile contant I have list of columns on of a table on which CDC is enabled, Based on a flag present in my flowfile-content I am getting all the column values whihc were updated in the form of an array, I am storing this array in a attribute
For each flowfile this attributes is getting generated.
Now, I have a static array which contains a list of allowed keys(this is not generated from flow file, its something i am using to check the values in my attribute)
I am trying to see if the values inside my attribute "myAttr" contains only the allowed keys
if all the values in myattr is present in AllowedKeys then i want to route it to success otherwise to failure
Please let me know how can i achieve this(preferably without ExecuteScript or custom processor)