Support Questions
Find answers, ask questions, and share your expertise
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Dynamically launch new ConnectWebSocket processors?

Dynamically launch new ConnectWebSocket processors?

New Contributor


my use case is the following:

  1. I download a list of values in JSON format from a HTTP endpoint
  2. I parse the values one by one with SplitJson, each flowfile now contains a single value, i.e. the string "webSocketStream1"
  3. 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?

I am using NiFi version


Don't have an account?
Coming from Hortonworks? Activate your account here