Apache NIFI 可以部署在单个大服务器上,也可以使用集群模式实现高可用性和伸缩性。以下是在集群模式下使用 Apache NIFI 的示例代码:
在实现 Apache NIFI 集群前,需要部署 ZooKeeper 服务器。在这里,我们配置一个仅使用单个 ZooKeeper 实例的集群:
tickTime=2000 initLimit=10 syncLimit=5 dataDir=/var/lib/zookeeper clientPort=2181
搜索并编辑 nifi.properties 文件。找到属性列表中的以下行:
nifi.zookeeper.connect.string= nifi.cluster.is.node=false nifi.cluster.node.address=
将这些属性更改为以下内容:
nifi.zookeeper.connect.string=192.0.0.1:2181 nifi.cluster.is.node=true nifi.cluster.node.address=192.0.0.1
搜索以下属性列表中的以下行:
nifi.cluster.node.protocol.port= nifi.remote.input.socket.port=
将这些属性更改为需要的值。在这里,我们将这两个属性的值设置为 8080:
nifi.cluster.node.protocol.port=8080 nifi.remote.input.socket.port=8080
保存更改并重启 Apache NIFI。现在,Apache NIFI 将以集群模式运行,并具有高可用性和伸缩性。