question Re: Trouble adding custom LoginModule to consumeKafkaRecord_2_6 Apache Nifi Flow in Support Questions

Trouble adding custom LoginModule to consumeKafkaRecord_2_6 Apache Nifi Flow

mr_jahurley — Thu, 04 Nov 2021 12:46:05 GMT

I am using the ConsumeKafkaRecord_2_6 processor to consume from kafka. I am trying to use a custom LoginModule. I have both a custom LoginModule and a custom CallbackHandler. I put my two classes in a jar then loaded the jar on the Nifi system. When the processor starts, I get this error:
Caused by: javax.security.auth.login.LoginException: unable to find LoginModule class: com.eek.my.auth.krb.SauKrbLoginModuleWrapper. I am not sure how to add the jar so that the processor will find my classes. The dynamic property I am adding to reference the custom class is sasl.jaas.config. So the value of that looks like this: sasl.jaas.config=com.eek.my.auth.krb.SauKrbLoginModuleWrapper required krbProvider=com.sun.security.auth.module.Krb5LoginModule;

Re: Trouble adding custom LoginModule to consumeKafkaRecord_2_6 Apache Nifi Flow

mr_jahurley — Thu, 04 Nov 2021 14:43:14 GMT

I am requesting now the nar for the ConsumeKafkaRecord be updated to include my new jar. Not sure if that is the only way for the processor to pick it up.

Re: Trouble adding custom LoginModule to consumeKafkaRecord_2_6 Apache Nifi Flow

mr_jahurley — Fri, 05 Nov 2021 13:09:18 GMT

After adding the jar to the consumeKafkaRecord NAR and bouncing the servers, I am no longer receiving the error. Now I am able to authenticate to Kafka using the GSSAPI SASL mechanism.