storm-kafka集成错误

问题描述 投票:1回答:2

我得到以下错误:curator jar指的是服务器类路径,它是mapr lib,它包括curator jar。

我没有将curator jar包装在最终的可执行jar中。请帮忙解决这个问题::

java.lang.NoSuchMethodError: org.apache.curator.utils.ZKPaths.mkdirs(Lorg/apache/zookeeper/ZooKeeper;Ljava/lang/String;ZLorg/apache/curator/utils/InternalACLProvider;Z)V
        at org.apache.curator.framework.imps.CreateBuilderImpl$11.call(CreateBuilderImpl.java:726) ~[curator-framework-2.9.0.jar:?]
        at org.apache.curator.framework.imps.CreateBuilderImpl$11.call(CreateBuilderImpl.java:703) ~[curator-framework-2.9.0.jar:?]
        at org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:107) ~[curator-client-2.7.1.jar:?]
        at org.apache.curator.framework.imps.CreateBuilderImpl.pathInForeground(CreateBuilderImpl.java:700) ~[curator-framework-2.9.0.jar:?]
        at org.apache.curator.framework.imps.CreateBuilderImpl.protectedPathInForeground(CreateBuilderImpl.java:477) ~[curator-framework-2.9.0.jar:?]
        at org.apache.curator.framework.imps.CreateBuilderImpl.forPath(CreateBuilderImpl.java:467) ~[curator-framework-2.9.0.jar:?]
        at org.apache.curator.framework.imps.CreateBuilderImpl.forPath(CreateBuilderImpl.java:44) ~[curator-framework-2.9.0.jar:?]
        at storm.kafka.ZkState.writeBytes(ZkState.java:76) ~[stormjar.jar:0.3-SNAPSHOT]
        at storm.kafka.ZkState.writeJSON(ZkState.java:70) ~[stormjar.jar:0.3-SNAPSHOT]
        at storm.kafka.PartitionManager.commit(PartitionManager.java:276) ~[stormjar.jar:0.3-SNAPSHOT]
        at storm.kafka.KafkaSpoutOld.commit(KafkaSpoutOld.java:203) ~[stormjar.jar:0.3-SNAPSHOT]
        at storm.kafka.KafkaSpoutOld.nextTuple(KafkaSpoutOld.java:164) ~[stormjar.jar:0.3-SNAPSHOT]
        at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:39) ~[stormjar.jar:0.3-SNAPSHOT]
        at backtype.storm.daemon.executor$fn__4615$fn__4630$fn__4661.invoke(executor.clj:610) ~[storm-core-0.10.0-mapr-1611.jar:0.10.0-mapr-1611]
        at backtype.storm.util$async_loop$fn__544.invoke(util.clj:479) [storm-core-0.10.0-mapr-1611.jar:0.10.0-mapr-1611]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141]
apache-kafka apache-storm
2个回答
0
投票

您的策展人jar版本不同步。你正在使用curator-client 2.7和curator-framework 2.9。确保所有Curator jar都是相同的版本。


-1
投票

导入HBase和Phoenix时我也犯了同样的错误。然后我在项目中排除了curator-client,并删除了错误。


<groupId>org.apache.phoenix</groupId>
            <artifactId>phoenix-core</artifactId>
            <version>4.14.1-HBase-1.4</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.curator</groupId>
                    <artifactId>curator-client</artifactId>
                </exclusion>
© www.soinside.com 2019 - 2024. All rights reserved.