[
https://issues.apache.org/jira/browse/STORM-3549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated STORM-3549:
----------------------------------
Labels: pull-request-available (was: )
> use of topology specific jaas conf doesn't work with kafka
> ----------------------------------------------------------
>
> Key: STORM-3549
> URL: https://issues.apache.org/jira/browse/STORM-3549
> Project: Apache Storm
> Issue Type: Bug
> Reporter: Aaron Gresch
> Assignee: Aaron Gresch
> Priority: Major
> Labels: pull-request-available
>
> {code:java}
> 2019-09-17 19:22:23.006 o.a.s.u.Utils Thread-22-line-reader-spout-executor[4,
> 4] [ERROR] Async loop died!
> org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:702)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:557)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:540)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault.createConsumer(ConsumerFactoryDefault.java:26)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault.createConsumer(ConsumerFactoryDefault.java:22)
> ~[stormjar.jar:?]
> at org.apache.storm.kafka.spout.KafkaSpout.open(KafkaSpout.java:147)
> ~[stormjar.jar:?]
> at
> org.apache.storm.executor.spout.SpoutExecutor.init(SpoutExecutor.java:148)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at
> org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:158)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at
> org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:55)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:425)
> [storm-client-2.0.1.y.jar:2.0.1.y]
> at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181]
> Caused by: org.apache.kafka.common.KafkaException:
> javax.security.auth.login.LoginException: Could not login: the client is
> being asked for a password, but the Kafka client code does not currently
> support obtaining a password from the user. not available to garner
> authentication information from the user
> at
> org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:86)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:70)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:83)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:623)
> ~[stormjar.jar:?]
> ... 10 more
> Caused by: javax.security.auth.login.LoginException: Could not login: the
> client is being asked for a password, but the Kafka client code does not
> currently support obtaining a password from the user. not available to garner
> authentication information from the user
> at
> com.sun.security.auth.module.Krb5LoginModule.promptForPass(Krb5LoginModule.java:940)
> ~[?:1.8.0_181]
> at
> com.sun.security.auth.module.Krb5LoginModule.attemptAuthentication(Krb5LoginModule.java:760)
> ~[?:1.8.0_181]
> at
> com.sun.security.auth.module.Krb5LoginModule.login(Krb5LoginModule.java:617)
> ~[?:1.8.0_181]
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> ~[?:1.8.0_181]
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> ~[?:1.8.0_181]
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> ~[?:1.8.0_181]
> at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_181]
> at javax.security.auth.login.LoginContext.invoke(LoginContext.java:755)
> ~[?:1.8.0_181]
> at
> javax.security.auth.login.LoginContext.access$000(LoginContext.java:195)
> ~[?:1.8.0_181]
> at javax.security.auth.login.LoginContext$4.run(LoginContext.java:682)
> ~[?:1.8.0_181]
> at javax.security.auth.login.LoginContext$4.run(LoginContext.java:680)
> ~[?:1.8.0_181]
> at java.security.AccessController.doPrivileged(Native Method)
> ~[?:1.8.0_181]
> at
> javax.security.auth.login.LoginContext.invokePriv(LoginContext.java:680)
> ~[?:1.8.0_181]
> at javax.security.auth.login.LoginContext.login(LoginContext.java:587)
> ~[?:1.8.0_181]
> at
> org.apache.kafka.common.security.authenticator.AbstractLogin.login(AbstractLogin.java:69)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.security.kerberos.KerberosLogin.login(KerberosLogin.java:110)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.security.authenticator.LoginManager.<init>(LoginManager.java:46)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.security.authenticator.LoginManager.acquireLoginManager(LoginManager.java:68)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:78)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:70)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:83)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:623)
> ~[stormjar.jar:?]
> ... 10 more
> 2019-09-17 19:22:23.196 o.a.s.e.e.ReportError
> Thread-22-line-reader-spout-executor[4, 4] [ERROR] Error
> java.lang.RuntimeException: org.apache.kafka.common.KafkaException: Failed to
> construct kafka consumer
> at org.apache.storm.utils.Utils$1.run(Utils.java:445)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181]
> Caused by: org.apache.kafka.common.KafkaException: Failed to construct kafka
> consumer
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:702)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:557)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:540)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault.createConsumer(ConsumerFactoryDefault.java:26)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault.createConsumer(ConsumerFactoryDefault.java:22)
> ~[stormjar.jar:?]
> at org.apache.storm.kafka.spout.KafkaSpout.open(KafkaSpout.java:147)
> ~[stormjar.jar:?]
> at
> org.apache.storm.executor.spout.SpoutExecutor.init(SpoutExecutor.java:148)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at
> org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:158)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at
> org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:55)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:425)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> ... 1 more
> Caused by: org.apache.kafka.common.KafkaException:
> javax.security.auth.login.LoginException: Could not login: the client is
> being asked for a password, but the Kafka client code does not currently
> support obtaining a password from the user. not available to garner
> authentication information from the user
> at
> org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:86)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:70)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:83)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:623)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:557)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:540)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault.createConsumer(ConsumerFactoryDefault.java:26)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault.createConsumer(ConsumerFactoryDefault.java:22)
> ~[stormjar.jar:?]
> at org.apache.storm.kafka.spout.KafkaSpout.open(KafkaSpout.java:147)
> ~[stormjar.jar:?]
> at
> org.apache.storm.executor.spout.SpoutExecutor.init(SpoutExecutor.java:148)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at
> org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:158)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at
> org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:55)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:425)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> ... 1 more
> Caused by: javax.security.auth.login.LoginException: Could not login: the
> client is being asked for a password, but the Kafka client code does not
> currently support obtaining a password from the user. not available to garner
> authentication information from the user
> at
> com.sun.security.auth.module.Krb5LoginModule.promptForPass(Krb5LoginModule.java:940)
> ~[?:1.8.0_181]
> at
> com.sun.security.auth.module.Krb5LoginModule.attemptAuthentication(Krb5LoginModule.java:760)
> ~[?:1.8.0_181]
> at
> com.sun.security.auth.module.Krb5LoginModule.login(Krb5LoginModule.java:617)
> ~[?:1.8.0_181]
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> ~[?:1.8.0_181]
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> ~[?:1.8.0_181]
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> ~[?:1.8.0_181]
> at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_181]
> at javax.security.auth.login.LoginContext.invoke(LoginContext.java:755)
> ~[?:1.8.0_181]
> at
> javax.security.auth.login.LoginContext.access$000(LoginContext.java:195)
> ~[?:1.8.0_181]
> at javax.security.auth.login.LoginContext$4.run(LoginContext.java:682)
> ~[?:1.8.0_181]
> at javax.security.auth.login.LoginContext$4.run(LoginContext.java:680)
> ~[?:1.8.0_181]
> at java.security.AccessController.doPrivileged(Native Method)
> ~[?:1.8.0_181]
> at
> javax.security.auth.login.LoginContext.invokePriv(LoginContext.java:680)
> ~[?:1.8.0_181]
> at javax.security.auth.login.LoginContext.login(LoginContext.java:587)
> ~[?:1.8.0_181]
> at
> org.apache.kafka.common.security.authenticator.AbstractLogin.login(AbstractLogin.java:69)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.security.kerberos.KerberosLogin.login(KerberosLogin.java:110)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.security.authenticator.LoginManager.<init>(LoginManager.java:46)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.security.authenticator.LoginManager.acquireLoginManager(LoginManager.java:68)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:78)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:70)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:83)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:623)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:557)
> ~[stormjar.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:540)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault.createConsumer(ConsumerFactoryDefault.java:26)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault.createConsumer(ConsumerFactoryDefault.java:22)
> ~[stormjar.jar:?]
> at org.apache.storm.kafka.spout.KafkaSpout.open(KafkaSpout.java:147)
> ~[stormjar.jar:?]
> at
> org.apache.storm.executor.spout.SpoutExecutor.init(SpoutExecutor.java:148)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at
> org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:158)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at
> org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:55)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:425)
> ~[storm-client-2.0.1.y.jar:2.0.1.y]
> ... 1 more
> 2019-09-17 19:22:23.277 o.a.s.u.Utils Thread-22-line-reader-spout-executor[4,
> 4] [ERROR] Halting process: Worker died
> java.lang.RuntimeException: Halting process: Worker died
> at org.apache.storm.utils.Utils.exitProcess(Utils.java:550)
> [storm-client-2.0.1.y.jar:2.0.1.y]
> at org.apache.storm.utils.Utils$3.run(Utils.java:846)
> [storm-client-2.0.1.y.jar:2.0.1.y]
> at
> org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:41)
> [storm-client-2.0.1.y.jar:2.0.1.y]
> at java.lang.Thread.dispatchUncaughtException(Thread.java:1959)
> [?:1.8.0_181]
> 2019-09-17 19:22:23.281 o.a.s.u.Utils Thread-26 [INFO] Halting after 1 seconds
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
