in my Nifi flows I have created 3 parameter context group each for an environment(DEV, SIT, PROD) respectively..... As of now whenever I migrate my flow to other environments , I manually select the paramater contexts based on the environment. I want to know if there is a way I can dynamically apply them without me manually selecting the parameter context groups manually Is there a way I can apply them dynamically ? ... View more

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 ex: myAttr:[123,456,789] 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) ex: AllowedKeys:[111,222,333,123,456,789] 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) ... View more