NiFi采用了Zero-Master聚类模式。集群中的每个节点都对数据执行相同的任务，但是每个节点都使用不同的数据集。其中一个节点会自动选择（通过Apache ZooKeeper）作为集群协调器。然后集群中的所有节点将向此节点发送心跳/状态信息,并且此节点负责断开一段时间内没有心跳的节点。另外，当新节点选择加入集群时，新节点必须首先连接到当前选择的集群协调器，以获得最新的流。如果集群协调器确定允许

1简介主题和日志分布式生产者消费者保证kafka作为消息系统卡夫卡作为存储系统kafka作为数据流处理整合2 使用案例消息处理Metrics度量日志收集流处理事件溯源Event Sourcing提交日志Commit Log3 快速开始Step 1 下载代码Step 2 启动服务Step 3 创建一个主题Step 4 发送消息Step 5 启动消费者Ste