0

我制作流程，它处理来自本地服务器的实时数据并将相关数据发送到 Elasticsearch。我使用 Minifi，但是当我运行 MiNifi 时，它返回了以下错误。有谁知道，问题出在哪里？

谢谢

错误 [Timer-Driven Process Thread-10] oanpelasticsearch.PutElasticsearch5 PutElasticsearch5[id=4ed70cbe-9838-35cd-0000-000000000000] PutElasticsearch5[id=4ed70cbe-9838-35cd-0000-000000000000] 由于 java.lang 处理失败。 NoClassDefFoundError：无法初始化类 org.elasticsearch.Version；回滚会话：{} java.lang.NoClassDefFoundError：无法在 org.elasticsearch.common.io.stream.StreamOutput.(StreamOutput.java:73) 在 org.elasticsearch.common.io 初始化类 org.elasticsearch.Version。 stream.BytesStreamOutput.(BytesStreamOutput.java:60) 在 org.elasticsearch.common.io.stream.BytesStreamOutput.(BytesStreamOutput.java:57) 在 org.elasticsearch.common.io.stream.BytesStreamOutput.(BytesStreamOutput.java:47 ) 在 org.elasticsearch.common.xcontent.XContentBuilder.builder(XContentBuilder.java:

4

1 回答 1

1

为了减少占用空间，MiNiFi java 仅附带标准的处理器包。为了在 MiNiFi 中使用标准 NiFi 部署中存在的其他处理器，您需要将适当的“nar”文件放入 MiNiFi 部署的“lib”中。

对于“PutElasticSearch”，您需要“nifi-elasticsearch-nar-.nar”，其中“”是您的 MiNiFi 版本所基于的 NiFi 版本。MiNiFi java 0.4.0 版本使用 NiFi 1.5.0。

有关更多信息和与 MiNiFi 捆绑在一起的处理器列表，请参阅“MiNiFi Java 代理快速入门”文档，“使用未与 MiNiFi 打包的处理器”[1] 部分。有关不同版本的 MiNiFi 的更多信息对应于 NiFi 框架的版本，请参见此处[2]。

[1] https://nifi.apache.org/minifi/minifi-java-agent-quick-start.html

[2] https://cwiki.apache.org/confluence/display/MINIFI/MiNiFi+Versioning+and+Toolkit+Compatibility

于 2018-02-05T15:58:32.467 回答