You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Yonghui Zhao <zh...@gmail.com> on 2014/04/17 15:32:23 UTC

zkclient version

Hi

I am trying kafka 0.8.1, and use zkclient version:

      <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.3</version>
        </dependency>


But I found exceptions in console,  is zkversion is wrong?

*java.lang.NoSuchMethodError:
org.I0Itec.zkclient.ZkClient.writeDataReturnStat(Ljava/lang/String;Ljava/lang/Object;I)Lorg/apache/zookeeper/data/Stat;*
    at
kafka.utils.ZkUtils$.conditionalUpdatePersistentPathIfExists(ZkUtils.scala:397)
    at
kafka.controller.KafkaController.incrementControllerEpoch(KafkaController.scala:662)
    at
kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:303)
    at
kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:161)
    at
kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
    at
kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:49)
    at
kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:47)
    at
kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:47)
    at kafka.utils.Utils$.inLock(Utils.scala:538)
    at
kafka.server.ZookeeperLeaderElector.startup(ZookeeperLeaderElector.scala:47)
    at
kafka.controller.KafkaController$$anonfun$startup$1.apply$mcV$sp(KafkaController.scala:630)
    at
kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:626)
    at
kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:626)
    at kafka.utils.Utils$.inLock(Utils.scala:538)
    at kafka.controller.KafkaController.startup(KafkaController.scala:626)
    at kafka.server.KafkaServer.startup(KafkaServer.scala:96)
    at
kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:34)

Re: zkclient version

Posted by Jun Rao <ju...@gmail.com>.
0.3 is the right version. Are you sure the 0.3 jar is included? That method
only exists in 0.3.

Thanks,

Jun


On Thu, Apr 17, 2014 at 6:32 AM, Yonghui Zhao <zh...@gmail.com> wrote:

> Hi
>
> I am trying kafka 0.8.1, and use zkclient version:
>
>       <dependency>
>             <groupId>com.101tec</groupId>
>             <artifactId>zkclient</artifactId>
>             <version>0.3</version>
>         </dependency>
>
>
> But I found exceptions in console,  is zkversion is wrong?
>
> *java.lang.NoSuchMethodError:
>
> org.I0Itec.zkclient.ZkClient.writeDataReturnStat(Ljava/lang/String;Ljava/lang/Object;I)Lorg/apache/zookeeper/data/Stat;*
>     at
>
> kafka.utils.ZkUtils$.conditionalUpdatePersistentPathIfExists(ZkUtils.scala:397)
>     at
>
> kafka.controller.KafkaController.incrementControllerEpoch(KafkaController.scala:662)
>     at
>
> kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:303)
>     at
>
> kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:161)
>     at
> kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
>     at
>
> kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:49)
>     at
>
> kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:47)
>     at
>
> kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:47)
>     at kafka.utils.Utils$.inLock(Utils.scala:538)
>     at
>
> kafka.server.ZookeeperLeaderElector.startup(ZookeeperLeaderElector.scala:47)
>     at
>
> kafka.controller.KafkaController$$anonfun$startup$1.apply$mcV$sp(KafkaController.scala:630)
>     at
>
> kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:626)
>     at
>
> kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:626)
>     at kafka.utils.Utils$.inLock(Utils.scala:538)
>     at kafka.controller.KafkaController.startup(KafkaController.scala:626)
>     at kafka.server.KafkaServer.startup(KafkaServer.scala:96)
>     at
> kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:34)
>