You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "David Handermann (Jira)" <ji...@apache.org> on 2022/12/01 13:31:00 UTC
[jira] [Assigned] (NIFI-10919) Regression in ConsumeKafkaRecord_2_0
[ https://issues.apache.org/jira/browse/NIFI-10919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
David Handermann reassigned NIFI-10919:
---------------------------------------
Assignee: David Handermann
> Regression in ConsumeKafkaRecord_2_0
> ------------------------------------
>
> Key: NIFI-10919
> URL: https://issues.apache.org/jira/browse/NIFI-10919
> Project: Apache NiFi
> Issue Type: Bug
> Affects Versions: 1.19.0
> Reporter: Anders
> Assignee: David Handermann
> Priority: Critical
>
> 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:
> {code}
> 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)
> {code}
> 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?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)