如何清除NiFi队列？
共有1个答案
除了Bryan提到的显式“丢弃队列”功能之外，您可能感兴趣的其他几个功能是连接上的“背压”和“流文件过期”设置。这些允许您自动控制任何给定连接中的数据量。下面是对每一种方法的简单解释，但要获得更详细的解释，请参阅Apache NiFi用户指南
背压：当一个队列达到一定的大小时，停止触发为其提供信息的处理器。
FlowFile过期：一旦一个FlowFile在队列中花费了X量的时间，它就会被丢弃。
-
问题内容： 可以以标准方式执行此操作吗？ 这是场景。 开始在EDT中执行一些昂贵的操作（EDT被阻止，直到昂贵的操作结束为止）。 在阻止EDT的同时，用户继续单击/拖动鼠标按钮。所有鼠标动作都记录在某处。 当EDT免费时（用昂贵的东西完成），它开始处理鼠标事件。 我在步骤3中想要的是丢弃堆积的鼠标事件。EDT释放后，任何新的鼠标事件都应按常规方式处理。 关于如何实现这一目标的任何想法。 PS：对于
-
问题内容： 我正在使用RQ，我有一个队列包含数千个项目，而另一个队列我创建了一段时间用于测试，现在已经空了并且没有使用。我想知道如何从队列中删除所有作业，然后完全删除队列？ 道歉的基本问题，但我无法在RQ文档中找到有关此信息，对于Redis和RQ来说，我都是新手…预先感谢！ 问题答案： RQ提供了使任何队列为空的方法： 如果仍然存在，也可以对队列执行相同的操作。 清理使用 安装rq-dashboa
-
如何从weblogic JMS队列中清除/删除消息 我的是一个集群环境，在服务中使用。 获取以下异常。
-
当Kubernetes pod进入状态时，您将修复底层问题。你怎么强迫它重新安排？
-
我试图找到类似的问题，但找不到解决我问题的最佳方案。我在应用程序中使用SpringBoot，在代码中使用集成的solace队列。我可以使用以下代码读取solace队列中的消息： 在SpringBoot的帮助下，所有属性（如VPN）都从属性文件中提取，并创建ConnectionFactory。下面是读取消息的代码： 根据消息的类型，定位服务执行器并处理消息。它对我们完全有效。 但是，在某些情况下，我
-
是否需要删除/清除Azure门户中Azure服务总线队列中的活动/死信消息？目前，我们已经向队列发送了几条消息，而活动消息和一些死信消息都无缘无故地保留在那里，并且我们的服务总线用户没有以某种方式触发，因此我们希望删除这些消息，以使队列再次干净。为了等到服务总线在过期后丢弃这些消息，我们可以自己手动删除它们吗？