集群通用属性
设置NiFi集群时，应在所有节点上以相同的方式配置这些属性。
| Property | Description |
|---|---|
| nifi.cluster.protocol.heartbeat.interval | 节点应该向集群协调器发出心跳的时间间隔。 默认值是5秒。 |
| nifi.cluster.protocol.is.secure | 这表示集群通信是否需要安全严证。 默认值是false。 |
集群节点属性
为集群节点配置这些属性。
| Property | Description |
|---|---|
| nifi.cluster.is.node | 如果实例是集群中的节点，则将其设置为true。 默认值是false。 |
| nifi.cluster.node.address | 将其设置为节点的标准主机名。 如果留空，则默认为“localhost”。 |
| nifi.cluster.node.protocol.port | 将其设置为高于1024的开放端口（任何更低的值都需要root权限）。 |
| 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秒。 |
| nifi.cluster.node.read.timeout | 当与集群中的另一个节点进行通信时，指定在认定与节点的通信失败之前，该节点应该等待从远程节点接收信息的时间。 默认值是5秒。 |
| nifi.cluster.firewall.file | 节点防火墙文件的位置。 这是一个可用于列出所有允许连接到群集的节点的文件。 它提供了一个额外的安全层。 该值默认为空白，表示不使用防火墙文件。 |
| nifi.cluster.flow.election.max.wait.time | 指定在将Flow选为“正确”Flow之前等待的时间量。 如果已投票的节点数量等于nifi.cluster.flow.election.max.candidates属性指定的数量，则集群不会等待这么久。 默认值是5分钟。 请注意，第一次投票后，时间就会开始。 |
| nifi.cluster.flow.election.max.candidates | 指定集群中提前选择流需要的节点数量。 这使得集群中的节点可以避免在开始处理之前等待很长时间，如果我们达到集群中至少这个数量的节点。 |
