[GitHub] [nifi] turcsanyip commented on pull request #6846: NIFI-10991 Add AWS MSK IAM support to Kafka processors

[GitBox <gi...@apache.org>]

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-unsubscribe@nifi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org