Hi all,
I really need to use storm-kafka in my project, too. However I do my best
effort and get the exception when running the topology. I download release
0.9.2 from GitHub and mvn compile and package and install to my .m2. The
exception is as follows:
7414 [Thread-20-FacebookSpout] ERROR backtype.storm.daemon.executor -
java.lang.NoSuchMethodError:
org.apache.zookeeper.ZooKeeper.<init>(Ljava/lang/String;ILorg/apache/zookeeper/Watcher;Z)V
at
org.apache.curator.utils.DefaultZookeeperFactory.newZooKeeper(DefaultZookeeperFactory.java:29)
~[curator-client-2.4.0.jar:na]
at
org.apache.curator.framework.imps.CuratorFrameworkImpl$2.newZooKeeper(CuratorFrameworkImpl.java:169)
~[curator-framework-2.4.0.jar:na]
at org.apache.curator.HandleHolder$1.getZooKeeper(HandleHolder.java:94)
~[curator-client-2.4.0.jar:na]
at org.apache.curator.HandleHolder.getZooKeeper(HandleHolder.java:55)
~[curator-client-2.4.0.jar:na]
at org.apache.curator.ConnectionState.reset(ConnectionState.java:219)
~[curator-client-2.4.0.jar:na]
at org.apache.curator.ConnectionState.start(ConnectionState.java:103)
~[curator-client-2.4.0.jar:na]
at
org.apache.curator.CuratorZookeeperClient.start(CuratorZookeeperClient.java:188)
~[curator-client-2.4.0.jar:na]
at
org.apache.curator.framework.imps.CuratorFrameworkImpl.start(CuratorFrameworkImpl.java:234)
~[curator-framework-2.4.0.jar:na]
at storm.kafka.ZkState.<init>(ZkState.java:62)
~[storm-kafka-0.9.2-incubating.jar:0.9.2-incubating]
at storm.kafka.KafkaSpout.open(KafkaSpout.java:85)
~[storm-kafka-0.9.2-incubating.jar:0.9.2-incubating]
at
backtype.storm.daemon.executor$eval5100$fn__5101$fn__5116.invoke(executor.clj:519)
~[na:na]
at backtype.storm.util$async_loop$fn__390.invoke(util.clj:431) ~[na:na]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_60]
The bothers me for lots of days. Can anyone use storm-kafka successfully, and
tell me how to do? I need the new feature of version 0.5 of storm-Kafka.
Sorry for asking question is the thread.
Best regards,
James
> Toni Menzel <[email protected]> 於 2014/6/20 下午10:41 寫道：
>
> ah ok thanks for heads up, Taylor.
> And just to know: will the storm-kafka subproject be released, too? It was
> not part of 0.9.1 though.
>
> Toni Menzel | rebaze GmbH
> [email protected] | +49 171 65 202 84
> http://www.rebaze.com | twitter @rebazeio | LinkedIn Profile
>
>
>
>> On Fri, Jun 20, 2014 at 4:34 PM, P. Taylor Goetz <[email protected]> wrote:
>> It has not been officially released yet. The PPMC voted to approve it, but
>> it still needs to be approved by the IPMC. That vote is currently underway.
>> Only when that succeeds can we release the artifacts from staging.
>>
>> -Taylor
>>
>>> On Jun 20, 2014, at 10:29 AM, Toni Menzel <[email protected]> wrote:
>>>
>>> Hi there,
>>>
>>> 1.
>>> i see storm 0.9.2-incubator has been released last friday? Any reason why
>>> its not on maven central yet [1] ?
>>>
>>> 2.
>>> Right now i am using the (external) kafka spout which right now has been
>>> built locally from master. Will it be released with the general
>>> distribution soon'ish?
>>>
>>> Thanks guys, Toni
>>>
>>> [1]
>>> http://search.maven.org/#artifactdetails%7Corg.apache.storm%7Cstorm-core%7C0.9.1-incubating%7Cjar
>>>
>>> Toni Menzel | rebaze GmbH
>>> [email protected] | +49 171 65 202 84
>>> http://www.rebaze.com | twitter @rebazeio | LinkedIn Profile
>
