【发布时间】:2019-05-16 20:47:36
【问题描述】:
谁能告诉我 Apache NiFi 中“执行”选项的用途是什么?
此选项适用于大多数处理器,我们目前可以选择 2 个值 - 主节点和所有集群。
我能想到的一个用例是 - 从 Kafka 读取数据并且您想要对读取进行负载平衡。
我可能对这个选项的使用感到困惑,因为它是为大多数处理器提供的。
【问题讨论】:
标签: apache-nifi
谁能告诉我 Apache NiFi 中“执行”选项的用途是什么?
此选项适用于大多数处理器,我们目前可以选择 2 个值 - 主节点和所有集群。
我能想到的一个用例是 - 从 Kafka 读取数据并且您想要对读取进行负载平衡。
我可能对这个选项的使用感到困惑,因为它是为大多数处理器提供的。
【问题讨论】:
标签: apache-nifi
仅主节点适用于源处理器应仅在一个节点上执行的情况。例如,如果您在 3 节点集群中的流程开始时有一个 GetSFTP 处理器,那么您不希望它在所有 3 个节点上运行,因为它们都会获得相同的文件。
仅主节点最常见的用法可能是 List + Fetch 模式。该流程从仅在主节点上运行的 ListHDFS 等列表处理器开始,然后是负载平衡连接,将列表分发到所有节点,连接到在所有节点上运行的 FetchHDFS。
https://pierrevillard.com/2018/10/29/nifi-1-8-revolutionizing-the-list-fetch-pattern-and-more/
不是流中第一个处理器的处理器永远不应真正设置为主节点,即使应用程序允许这样做。这可能会得到改善。
【讨论】: