我们正在尝试将NiFi连接到我们设置为使用Confluent Schema Registry的Confluent Kafka实例,因为我们正在以Avro格式发布/使用消息。 但是,当我们启动NiFi kafka处理器时,会出现以下异常: Failed to retrieve Schema with subjects array from any of the Confluent Schema Registry URL's provided; failure response message: User cannot…

2020年11月23日 0条评论 81点热度 阅读全文

我对使用证书和安全性还很陌生,所以请原谅我。我遵循this guide设置了Grails应用程序,使其可以在具有自签名证书的HTTPS上运行。 我正在尝试与在同一机器上运行的另一个HTTPS网络(Nifi独立实例)建立2路SSL。我可以让Nifi实例通过HTTPS与Grails进行对话,但是我在Grails与Nifi(特别是与ListenHTTP处理器)对话时遇到了问题。 我希望有人可以建议通过HTTPS发布时如何在Grails中使用证书身份验证。 Nifi使用证书身份验证;但是,根据以上指南,Grails仅指定了…

2020年8月29日 0条评论 47点热度 阅读全文

嗨, 我正在使用GetSNMP处理器来连接无线电。根据NiFi文档,这些信息被写入流文件属性而不是流文件内容。所以,我使用了AttributesToJSON处理器。之后,我使用PutFile处理器将这些属性写入文件。生成文件,但没有写入属性。每个文件中只写入“{}”。使用LogAttribute处理器,我可以看到日志文件中的所有属性,但我希望它们在单独的文件中。 请指导。将属性写入Apache NiFi中的文件 感谢, ===========解决方案如下: SGaur, 如果传入的流文件内容PUTFILE处理器之前…

2020年8月19日 0条评论 141点热度 阅读全文

我已经使用了youtube api URL https://www.googleapis.com/youtube/v3/commentThreads?key= *****&textFormat = plainText&part = snippet&videoId = XhtNooh2gws&maxResults = 50 使用Nifi GetHttp处理器时,还将SSL上下文服务设置为StandardSSLContextService。但这在运行处理器时给我以下错误 javax.net.SSL.PeerUnveri…

2020年8月1日 0条评论 72点热度 阅读全文

我已经使用了youtube api URL https://www.googleapis.com/youtube/v3/commentThreads?key= *****&textFormat = plainText&part = snippet&videoId = XhtNooh2gws&maxResults = 50 使用Nifi GetHttp处理器时,还将SSL上下文服务设置为StandardSSLContextService。但这在运行处理器时给我以下错误 javax.net.SSL.PeerUnveri…

2020年7月28日 0条评论 53点热度 阅读全文

我正在尝试在Apache NiFi中开发自定义处理器,该处理器将orc文件直接写入远程hadoop集群。为了编写它们,我使用了orc core api。我尝试将文件写在本地FS上,但它们没有问题: hive ,这是它们的“最终目标”,在读取它们时没有问题。 问题是,在尝试创建Writer对象时,我为类 org.apache.hadoop.hdfs.DistributedFileSystem 收到了 NoClassDefFoundError 。 那是使用的代码: Configuration conf = new Co…

2020年7月18日 0条评论 50点热度 阅读全文

是否可以从Java应用程序调用Apache Nifi ListenHTTP处理器或HandleHttpRequest?另外,如何从Java应用程序将自定义参数发送到ListenHTTP“远程URL”属性? 如何通过Java API设置处理器的属性? 如何通过URL将参数传递给Nifi处理器组?以及如何通过该URL启动处理器组。 http://localhost:8080/api/firstname/{first_name}/lastname/{last_name} 我想将我的Java应用程序中的first_name…

2020年7月17日 0条评论 99点热度 阅读全文

创建我的Nifi处理器类的实例(下面的代码)时,出现ExceptionInIntializer错误。联机查看后,此错误是由静态初始化程序中的错误导致的,而我在我的课程中没有这个错误。我的代码中还有其他可能导致此错误的内容吗? import ApplicationProperties; import IndexAttributesUtil; import ConvertRecordUtil; import EntityTypeUpdates; import ViewTypeUtil; import QueryHelp…

2020年7月12日 0条评论 30点热度 阅读全文

我们一直在为Nifi使用定制的处理器集,并且在使用命令mvn clean install时它们可以很好地编译。但是,我们目前正在尝试重构代码,以便将静态函数的集合以及其他重复的代码都移到处理器继承的单个基类中。 这个基类(我们称它为BaseProcessor)继承了AbstractProcessor类并实现了大多数。然后,我们的其他处理器继承此BaseProcessor并向其添加自己的代码,然后根据需要调用基类函数(例如,获取JWT令牌并发出GET / PUT / POST请求)。 重构完成后,Eclipse和Ma…

2020年7月8日 0条评论 49点热度 阅读全文

我正在测试NIFI中的流程,该流程使用REST API检查计数器的特定值。我能够从REST响应中提取正确的值。但是,当我检查“属性处理器上的路由”中的条件时,预期匹配条件的结果将路由到不匹配的处理器。Nifi:将属性处理器路由到错误的处理器 附件为: Flow和configuration 我已经检查了我的回应是 “1”。但它的路由到不匹配的分支。 我使用的NIFI表达式语言有什么问题吗? ===========解决方案如下: 贾西姆, 初始设置检查计数器属性,其中值为1 并修改等${counter:equals('…

2020年6月22日 0条评论 72点热度 阅读全文