Walkthrough applies to 2.0, or not?

2024-04-02 Thread James McMahon
Hello. I am preparing to install NiFi 2.0. I am reading this: https://nifi.apache.org/documentation/nifi-2.0.0-M2/html/walkthroughs.html The link would seem to indicate that it applies to NiFi 2.0, but all the details in the writeup reference 1.11.4. Is there anything in this walkthrough that does

Handling a portion of a flowfile as a byte stream in Groovy

2021-08-19 Thread James McMahon
I have a series of data files that have two sections: headers that are text which I want to alter using regex patterns, and a payload following the text portion that is encoded data. I call a groovy script from an ExecuteScript processor, employing an inputStream and outputStream callback to make

How does logging level get set?

2018-09-11 Thread James McMahon
Good morning. I am confused about logging levels from within java code that defines a nar. I have a java class file AMQPWorker.java, within which I establish a logger used throughout my nar. This is what I inherited in the class: abstract class AMQPWorker implements AutoCloseable { private f

User, Group in LDAP appear to be unknown to PutFile

2018-05-29 Thread James McMahon
Good evening. I have recently migrated my nifi service host server from local resolution of users and groups to use an LDAP server. I configured login-identity-providers.xml and nifi.security.user.login.identity.provider. I verified my configuration is known to NiFi by first restarting my nifi serv

Handling an error and sys.exit from python in ExecuteScript

2018-05-16 Thread James McMahon
Hello. I am using an ExecuteScript processor to run a python script in the NiFi jython environment. Early in my script I try to get user and group info from my ldap server. It works, but I want to properly handle the case where the ldap server is down. If it is down and I get an ldap error in the f

Questions re: customizing a NiFi processor

2017-12-02 Thread James McMahon
Good evening. I am familiar with NiFi and have developed a number of workflows using out -of-the-box processors. I now need to develop a custom version of PublishAMQP that permits the use of attributes in expression language to set specs for the AMQP target. I am not very familiar with Maven, but