NiFi - 停止处理器后线程仍然运行

Question

我正在使用 Eclipse Milo 为 Apache NiFi 开发一个发布订阅处理器。 我有一个服务来处理与 Eclipse Milo 和服务器的大部分交互，还有一个控制器，它基本上只是调用服务的功能。 订阅 OPCUA 服务器上的节点工作正常，但我想不出终止订阅的好方法，例如当我停止处理器时。 在服务中“存在”的订阅在服务被禁用以及控制器被禁用/停止后仍然存在。这意味着我定义的 @OnStopped 和 @OnUnscheduled 方法永远不会被调用，可能是因为订阅永远不会被终止。所以我不能使用这两种方法。 我知道我可以在 NiFi 1.7+ 中终止线程，但我认为这不是处理这个问题的好方法，而且我仍在使用 1.2。 有人有什么建议吗？

Answer 1

更新到最新版本，修复了处理器完成方式的一些问题。