Yes, I am getting nodeAddress and its status from "rest-api/controller/cluster" for create http endpoint. I will send flowFile to other active nodes after i prepare URL. For example; Result of "rest-api/controller/cluster"; {
"cluster": {
"nodes": [
{
"nodeId": "node1Id" ,
"address": "node1Address",
"apiPort": 9999,
"status": "CONNECTED",
"heartbeat": "value",
"connectionRequested": "value",
"roles": [],
"activeThreadCount": 0,
"queued": "value",
"events": [{
"timestamp": "value",
"category": "value",
"message": "value"
}],
"nodeStartTime": "value"
},
{
"nodeId": "node2Id" ,
"address": "node2Address",
"apiPort": 9999,
"status": "CONNECTED",
"heartbeat": "value",
"connectionRequested": "value",
"roles": ["PRIMARY"],
"activeThreadCount": 0,
"queued": "value",
"events": [{
"timestamp": "value",
"category": "value",
"message": "value"
}],
"nodeStartTime": "value"
}
],
"generated": "value"
}
}<br> I get node1Address and node2Address(if they CONNECTED) values from this json. Then, I am creating URL like this; http://node1Address:9999/contentListener Then, I will send post request to listenHttp(running on each node) using postHttp with this URL. ListenHttp(running on the each node) will listen to the this path and retrieve the data.
... View more
