Hi,   Can you explain how can I use config files inside code which are defined under src/main/resources folder ?   I tried using standard Java approach via getResourceAsStream() or getResource() methods to access resources under classpath. But in Ni-fi, while execution it outputs IllegalArgumentException.  ... View more

Thanks for the update. ... View more

@Artem Ervits it's dummy data. ... View more

step1 : remove the authorization.xml from all the nodes rm /var/lib/nifi/conf/authorizations.xml step2 : update node identities in advanced_nifi_ambari_ssl_configuration section with <property name="Node Identity 1">CN=hostname1, OU=XXXXX</property> ... for all the nodes (make sure you remove comment tags in XML). step3 : restart the NiFi service found that authorizations.xml is not being update after first generation, hence this is causing the problem. ... View more

Yup, if you specify the Message Demarcator it will write all of the messages received in a single poll from Kafka to a single FlowFile, so it would be a maximum of "Max Poll Records" per flow file, but could be less if it received less from Kafka. ... View more

i tried deleting the connection flow, it didn't work as well. later i restarted NIFI and processor came out of indefinite block state. ... View more

It would probably be best to start a new question for this, but... If you have three different CAs that were used to generate three different certs for each of your standalone nodes, then you will need to create a single truststore that has the public keys of all three CAs, and each NiFi node will need to use that trutstore in order to trust the other nodes. The initial admin identity must be the same on all nodes. If you have a client cert that worked on one of your standalone nodes, and if you do what I described above with the truststore, then you can still use this client cert. Each node, will need all the node identities listed. You will also need to delete the users.xml and authorizations.xml from each node so that it starts over. ... View more

If you added the correct dependencies in your processor's pom file then they should be getting included in the generated NAR, as Andrew mentioned above. Please verify you have the correct project structure described here: https://cwiki.apache.org/confluence/display/NIFI/Maven+Projects+for+Extensions#MavenProjectsforExtensions-ProcessorProjects There should be a Maven project with two sub-modules, one for the processors JAR where you would put your dependencies in the pom file, and another for building the NAR. ... View more

+1 to mclarke's solution. ... View more

@Pierre Villard thanks for your response. I am definitely gonna try this approach. ... View more