Created on 06-28-202301:01 AM - edited on 06-29-202310:43 PM by VidyaSargur
After upgrading to CFM 2.1.5 SP1from an older version, PublishKafkaRecord_1_0 stops working with the below error:
PublishKafka_1_0[id=36f1cffe-503d-3181-a562-ae216b5616b5] Processing halted: yielding [1 sec] java.lang.IllegalArgumentException: SaslMechanism value [null] not found at org.apache.nifi.kafka.shared.property.SaslMechanism.lambda$getSaslMechanism$1 (SaslMechanism.java:57) at java.base/java.util.Optional.orElseThrow(Optional.java:408) at org.apache.nifi.kafka.shared.property.SaslMechanism.getSaslMechanism(SaslMechanism. java:57) at org.apache.nifi.kafka.shared.login.DelegatingLoginConfigProvider. getConfiguration(DelegatingLoginConfigProvider.java:51) at org.apache.nifi.kafka. shared.property.provider.StandardKafkaPropertyProvider.setSecurityProperties (StandardKafkaPropertyProvider.java:86) at org.apache.nifi.kafka.shared.property. provider.StandardKafkaPropertyProvider.getProperties(StandardKafkaPropertyProvider. java:75)
This happens due an improvement performed in NIFI-10866.
Resolution
You can switch to newer PublishKafkaRecord processor like PublishKafkaRecord_2_0 or PublishKafkaRecord_2_6, both of which successfully eliminate the issue and also provide newer features as compared to the older 1_0 processor.