Dear Community

I have installed and configured a 3 node secured NiFi cluster with NiFi
1.13.2, Java 8 on Ubuntu 20.04.
I was wondering why the cluster didn't load balance flowfiles after I
configured Round Robins between a ListFTP and FetchFTP Process. (Other
mails earlier today: Round Robin not working NiFi)
After many attempt to find and fix the issues I notes that the load balance
port 6342 was bind to localhost and not 0.0.0.0.

> netstat -l
Active Internet connections (only servers)
Proto Recv-Q Send-Q Local Address           Foreign Address         State
tcp        0      0 0.0.0.0:9090            0.0.0.0:*               LISTEN
tcp        0      0 0.0.0.0:9443            0.0.0.0:*               LISTEN
tcp        0      0 localhost:6342          0.0.0.0:*               LISTEN
tcp        0      0 localhost:42603         0.0.0.0:*               LISTEN
tcp        0      0 0.0.0.0:ssh             0.0.0.0:*               LISTEN
tcp        0      0 node01.domain.com:8443 0.0.0.0:*               LISTEN
tcp6       0      0 localhost:42101         [::]:*                  LISTEN
tcp6       0      0 [::]:ssh                [::]:*                  LISTEN
raw6       0      0 [::]:ipv6-icmp          [::]:*                  7

Part of the configuration is like this:
nifi.web.https.host=node1.domain.com
nifi.web.https.port=8443
nifi.web.https.network.interface.default=ens192
nifi.cluster.is.node=true
nifi.cluster.node.address=node01.domain.com
nifi.cluster.node.protocol.port=9443
nifi.cluster.node.protocol.threads=10
nifi.cluster.node.protocol.max.threads=50
nifi.cluster.node.event.history.size=25
nifi.cluster.node.connection.timeout=5 sec
nifi.cluster.node.read.timeout=5 sec
nifi.cluster.node.max.concurrent.requests=100
nifi.cluster.firewall.file=
nifi.cluster.flow.election.max.wait.time=5 mins
nifi.cluster.flow.election.max.candidates=3

# cluster load balancing properties #
nifi.cluster.load.balance.host= node01.domain.com
nifi.cluster.load.balance.port=6342
nifi.cluster.load.balance.connections.per.node=4
nifi.cluster.load.balance.max.thread.count=8
nifi.cluster.load.balance.comms.timeout=30 sec

Errors in nifi-app.log
2021-06-10 16:00:22,078 ERROR [Load-Balanced Client Thread-1]
org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient
Unable to connect to node3.domain.com:8443 for load balancing
java.net.ConnectException: Connection refused
2021-06-10 16:00:22,078 ERROR [Load-Balanced Client Thread-1]
org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient
Unable to connect to node2.domain.com:8443 for load balancing
java.net.ConnectException: Connection refused

The question is:
Why does the error messages say: Unable to connect to node2.domain.com:8443
for load balancing
Shouldn't it be port 6342?????
Why does this port bind to localhost while all other ports bind to 0.0.0.0
or node01.domain.com???

kind regards
Jens

Reply via email to