ERROR|2017-05-27 16:41:17,941|10|11|1.2.3|com.aliyun.openservices.loghub.stormspout.LogHubSpout|activate(117)|failed to start the client to fetch data com.aliyun.openservices.loghub.client.exceptions.LogHubClientWorkerException: error occour when create consumer group, errorCode: Unauthorized, errorMessage: denied by sts or ram, action: log:CreateConsumerGroup, resource: acs:log:cn-beijing:1654109041909600:project/jike-test/logstore/log_teacher/consumergroup/conumser_group_1
at com.aliyun.openservices.loghub.client.ClientFetcher.<init>(ClientFetcher.java:83) ~[loghub-client-lib-0.6.7.jar:?]
at com.aliyun.openservices.loghub.stormspout.LogHubSpout.activate(LogHubSpout.java:109) [loghub-storm-1.0-spout-0.1.1.jar:?]
at org.apache.storm.daemon.executor$fn__4905$fn__4920$fn__4951.invoke(executor.clj:639) [storm-core-1.0.3.jar:1.0.3]
at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.0.3.jar:1.0.3]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]
ERROR|2017-05-27 16:41:30,674|10|11|1.2.3|org.apache.storm.shade.clojure.tools.logging$eval1$fn__7|invoke(0)|Async loop died! java.lang.NullPointerException
at com.aliyun.openservices.loghub.stormspout.LogHubSpout.nextTuple(LogHubSpout.java:142) ~[loghub-storm-1.0-spout-0.1.1.jar:?]
at org.apache.storm.daemon.executor$fn__4905$fn__4920$fn__4951.invoke(executor.clj:644) ~[storm-core-1.0.3.jar:1.0.3]
at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.0.3.jar:1.0.3]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]
ERROR|2017-05-27 16:41:30,677|10|11|1.2.3|org.apache.storm.shade.clojure.tools.logging$eval1$fn__7|invoke(0)| java.lang.NullPointerException
at com.aliyun.openservices.loghub.stormspout.LogHubSpout.nextTuple(LogHubSpout.java:142) ~[loghub-storm-1.0-spout-0.1.1.jar:?]
at org.apache.storm.daemon.executor$fn__4905$fn__4920$fn__4951.invoke(executor.clj:644) ~[storm-core-1.0.3.jar:1.0.3]
at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.0.3.jar:1.0.3]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]
ERROR|2017-05-27 16:41:30,788|10|11|1.2.3|org.apache.storm.shade.clojure.tools.logging$eval1$fn__7|invoke(0)|Halting process: ("Worker died") java.lang.RuntimeException: ("Worker died")
at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) [storm-core-1.0.3.jar:1.0.3]
at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?]
at org.apache.storm.daemon.worker$fn__5571$fn__5572.invoke(worker.clj:759) [storm-core-1.0.3.jar:1.0.3]
at org.apache.storm.daemon.executor$mk_executor_data$fn__4792$fn__4793.invoke(executor.clj:274) [storm-core-1.0.3.jar:1.0.3]
at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:494) [storm-core-1.0.3.jar:1.0.3]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]
请问这是什么问题呢,刚学习使用,请拍砖
添加日志信息后,显示
failed to start the client to fetch data com.aliyun.openservices.loghub.client.exceptions.LogHubClientWorkerException: error occour when create consumer group,这是什么原因呢
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。