java - 未调用自定义 nifi 处理器 TO Enable 注释

Question

我有一个处理器启动与 Elasticsearch 的连接，我在一个带有 @OnEnabled 注释的方法上进行此连接，但未调用此方法:

@OnEnabled
public void onEnabled(final ConfigurationContext configurationContext) {
 <code connection goes here>
}

我已经尝试了 onTrigger 方法上的连接并且它有效，但这会杀死机器。

我的处理器扩展自 AbstractProcessor 方法。

Answer 1

您可能需要在启动处理器时调用@OnScheduled，然后关闭@OnStopped 中的连接。

另一种选择是在 onTrigger 中延迟创建连接，方法是检查连接是否为空，如果为空则初始化它。

在此处查看@OnEnabled 的说明:

https://nifi.apache.org/docs/nifi-docs/html/developer-guide.html#component-lifecycle

"Note that this annotation will be ignored if applied to a ReportingTask or Processor. For a Controller Service, enabling and disabling are considered lifecycle events, as the action makes them usable or unusable by other components."