turcsanyip commented on PR #6846:
URL: https://github.com/apache/nifi/pull/6846#issuecomment-1387109383
@nandorsoma There seems to be regression in the kerberos login.
I get the error below when trying to connect to a kerberized kafka using
SASL_SSL + GSSAPI. I built the processors without the new include-kafka-aws
profile. The same flow works with the version on the current main branch.
```
2023-01-18 14:28:17,992 WARN [Timer-Driven Process Thread-9]
o.a.n.controller.tasks.ConnectableTask Processing halted: uncaught exception in
Component [PublishKafka_2_6[id=c49ff5ca-0185-1000-d5c3-1f042d05afeb]]
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:441)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:273)
at
org.apache.nifi.processors.kafka.pubsub.PublisherPool.createLease(PublisherPool.java:88)
at
org.apache.nifi.processors.kafka.pubsub.PublisherPool.obtainPublisher(PublisherPool.java:78)
at
org.apache.nifi.processors.kafka.pubsub.PublishKafka_2_6.onTrigger(PublishKafka_2_6.java:444)
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.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IllegalArgumentException: Value not specified for key
'required' in JAAS config
at
org.apache.kafka.common.security.JaasConfig.parseAppConfigurationEntry(JaasConfig.java:116)
at
org.apache.kafka.common.security.JaasConfig.<init>(JaasConfig.java:63)
at
org.apache.kafka.common.security.JaasContext.load(JaasContext.java:90)
at
org.apache.kafka.common.security.JaasContext.loadClientContext(JaasContext.java:84)
at
org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:134)
at
org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:73)
at
org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:105)
at
org.apache.kafka.clients.producer.KafkaProducer.newSender(KafkaProducer.java:449)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:430)
... 16 common frames omitted
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@nifi.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
