I download a list of values in JSON format from a HTTP endpoint
I parse the values one by one with SplitJson, each flowfile now contains a single value, i.e. the string "webSocketStream1"
With the ExtractText processor I extract the content to an attribute called "streamName"
Now I want to launch up a ConnectWebSocket processor for every stream name I have. The rest of my NiFi flow is identical for every ConnectWebSocket processor. I do not want to do this statically because the number of streams I want to connect to varies each day.
How can I dynamically start up new ConnectWebSocket processors?