一种在NiFi拓扑内收集用户输入的方法
我是NiFi的新手，所以我不确定这是否可能（或者是一种正确的设计方法）：
- 提示用户输入（通过
posthttp处理器） - 接收用户输入（通过
ListEnhTTP处理器）
通知==>后续处理
不幸的是，posthttp处理器将FlowFile的所有内容发布到指定的endpoint...这个endpoint的大小也可能是多GB...这是令人望而却步的。
共有1个答案
一种可能的方法是将文件写出到临时存储（本地磁盘、HDFS、S3等），写一个用户操作请求，然后基本上完全退出NiFi。然后，在用户采取操作后，流将重新启动。要触发重新启动，您可以将UI post到NiFi、写入消息队列或将另一个文件写入NiFi正在轮询的目录。
我认为这将更灵活地管理用户交互，因为您不必在HTTP post周期中完成整个UI响应。
-
> 灵光升起 StormUI启动 我使用的两个工人都起来了 Zookeper已启动 我和暴风一起跑 Storm罐myjar.jar MyClass Nimbus提交拓扑 该拓扑的日志文件不会出现在workers中。 我在supervisor.log上的worker中有以下日志： 所以我确信我与nimbus有连接问题，但是worker中的属性文件是： 错误在哪里，我如何修复它？ 谢了！
-
这个拓扑运行正常，不知道是什么原因导致这个问题。
-
我读了很多和Storm有关的网站。但我仍然无法将拓扑结构完美地映射到Storm集群中。 请帮助我理解这一点。 在Storm集群中有这样的术语 null null null 所有这些都要用Storm集群来映射。我已经在一个项目里工作了。所以我知道拓扑结构。
-
让我明确一点--我试图使用Twilio STUDIO来实现这一点--而不是编码。我有一个完整的IVR构建和工作，但我不知道如何保存呼叫者输入的选择(DTMF)。是否有一个简单的插件或addon可以节省用户输入？
-
本文向大家介绍环形拓扑和网格拓扑之间的区别，包括了环形拓扑和网格拓扑之间的区别的使用技巧和注意事项，需要的朋友参考一下 环形拓扑 在环形拓扑中，每个节点都以环形方式连接到其左节点和右节点，信息可以从一个节点流向另一个方向。如果有n个节点，则存在n个链接。如果要添加一个新节点，则整个连接将被中断。 网格拓扑 在网状拓扑中，每个节点使用其自己的专用链接连接到其他节点，并且信息可以从这些链接传播到任何节
-
我试图在storm Clustre上部署一个简单的字数拓扑。我使用kafka作为输入（kafka Spout）。这是我得到的错误 java.lang.noClassDefFoundError：无法初始化类org.apache.log4j.log4jLogger.getLogger(logger.java:39)在kafka.utils.logging$class.logger(logger.sca