Storm-kafka 集成错误答案

【问题标题】：storm-kafka integration errorStorm-kafka 集成错误
【发布时间】：2019-04-29 16:33:39
【问题描述】：

我遇到以下错误：curator jars 指的是服务器类路径，它是 mapr lib，它包括 curator jars。

我没有将 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

【解决方案1】：

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

【讨论】：

【解决方案2】：

我在导入 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>

【讨论】：