Multiple Values for Nifi.Remote.Input.Socket.Port

[#1]

I'm sending data from a MiNiFi agent to a NiFi Cluster. I set port 1026 for the nifi.remote.input.socket.port in the site to site properties section of the nifi.properties file in the NiFi cluster to get these data. I want to add another MiNiFi agent for sending some different data to the previously mentioned NiFi Cluster. So I want to add another port in the nifi.remote.input.socket.port for distinct receiving values in the NiFi cluster from MiNiFi agents. How can I add multiple values for nifi.remote.input.socket.port and if it is not possible, how can I handle receiving different values in the same NiFi cluster from MiNiFi agents.

Nifi version: 1.8.0
MiNiFi version: 0.5.0 java

[#2 · Accepted solution]

@Arash 

The "nifi.remote.input.socket.port" property is used so that the receiving NiFi can support the RAW transport protocol.  This port has nothing to do with where within your dataflows the transferred data is being ingested.

The Remote Process Group (RPG) that exists within your MiNiFi dataflow acts as a client.  It will execute a background thread every 30 seconds that connects to the target NiFi URL configured in the RPG that fetches NiFi Site-To-Site (S2S) details from the target NiFi.  These S2S details include details about the target.  This information includes but is not limited to the following:
1. Hostnames of all nodes in target NiFi cluster
2. Remote (RAW) input socket port if configured
3. FlowFile load on each cluster node
4. Remote input and output ports this client is authorized access to.

There is no option to configure multiple remote input socket port values.  RPG would not know how to use them even if there was.  In your case each unique MiNiFi should have be pushing to a different Remote input port on the canvas instead of all of them sending to same input port.  

Second option is to use a RouteOnAttribute processor after your single Remote input port that routes data based on the "s2s.host" attribute value set on the received FlowFiles.  This attribute is set by the sending RPG on each MiNiFi to the hostname of that MiNiFi.  You could of course also set a unique attribute on each FlowFile via na UpdateAttribute processor on each MiNiFi also before sending through the RPG.

If you found this addressed your query, please take a moment to login and click "Accept" on solutions that helped you.
Thank you,

Matt