[NIFI-10919] Regression in SCRAM SASL Mechanism handling in Kafka Processors

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.19.0
• Fix Version/s: 1.19.1
• Component/s: Extensions
• Assignee: David Handermann
• Reporter: Anders
• Created: 01/Dec/22 13:04
• Updated: 01/Dec/22 19:15
• Resolved: 01/Dec/22 19:15

Description

Just attempted to upgrade from version 1.17.0 to 1.19.0, and I'm now getting the following error message in ConsumeKafkaRecord_2_6:

2022-12-01 13:16:31,886 ERROR [Timer-Driven Process Thread-10] o.a.n.p.k.pubsub.ConsumeKafkaRecord_2_6 ConsumeKafkaRecord_2_6[id=8cd134b7-ae49-19d2-0000-00007edbb2f4] Processing halted: yielding [1 sec]
java.lang.IllegalArgumentException: No enum constant org.apache.nifi.kafka.shared.property.SaslMechanism.SCRAM-SHA-512
        at java.base/java.lang.Enum.valueOf(Enum.java:240)
        at org.apache.nifi.kafka.shared.property.SaslMechanism.valueOf(SaslMechanism.java:24)
        at org.apache.nifi.kafka.shared.login.DelegatingLoginConfigProvider.getConfiguration(DelegatingLoginConfigProvider.java:50)
        at org.apache.nifi.kafka.shared.property.provider.StandardKafkaPropertyProvider.setSecurityProperties(StandardKafkaPropertyProvider.java:83)
        at org.apache.nifi.kafka.shared.property.provider.StandardKafkaPropertyProvider.getProperties(StandardKafkaPropertyProvider.java:72)
        at org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_2_6.createConsumerPool(ConsumeKafkaRecord_2_6.java:427)
        at org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_2_6.getConsumerPool(ConsumeKafkaRecord_2_6.java:399)
        at org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_2_6.onTrigger(ConsumeKafkaRecord_2_6.java:519)
        at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
        at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1356)
        at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:246)
        at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:102)
        at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
        at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
        at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
        at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.base/java.lang.Thread.run(Thread.java:829)

I'm guessing this might be related to https://issues.apache.org/jira/browse/NIFI-10819. I don't speak Java, but guessing it might further be related to https://github.com/apache/nifi/pull/6690/commits/23eac09f05354aa6775e8504fd94ca2bb8c44c62#diff-e3bf34d8321c19887e4e1d2d3474eccfeb55d13ee7f5efbcaaa8964813c2485aR31
Should either the value be SCRAM_SHA_512 or the name of the property/variable/whateveritsnamedinjava be SCRAM-SHA-512?

Issue Links

• relates to: NIFI-10819 Restrict Modules in sasl.jaas.config Kafka Client Property
• links to: GitHub Pull Request #6743