Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - Exception with kafka 0.8


Copy link to this message
-
Re: Exception with kafka 0.8
Jun Rao 2013-08-07, 14:40
What's the host/port registered under /brokers/ids/[brokerId] in ZK?

Thanks,

Jun
On Wed, Aug 7, 2013 at 1:40 AM, 小宇 <[EMAIL PROTECTED]> wrote:

> Hi,I'm new to kafka, and i follow the quickstart guide, when i come to the
> Step 2,i run bin/kafka-server-start.sh config/server.properties  , but got
> exception:
> [2013-08-06 09:55:14,603] INFO 0 successfully elected as leader
> (kafka.server.ZookeeperLeaderElector)
> [2013-08-06 09:55:14,657] ERROR Error while electing or becoming leader on
> broker 0 (kafka.server.ZookeeperLeaderElector)
> java.net.SocketException: invalid argument
>     at sun.nio.ch.Net.connect0(Native Method)
>     at sun.nio.ch.Net.connect(Net.java:465)
>     at sun.nio.ch.Net.connect(Net.java:457)
>     at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:639)
>     at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
>     at
>
> kafka.controller.ControllerChannelManager.kafka$controller$ControllerChannelManager$$addNewBroker(ControllerChannelManager.scala:84)
>     at
>
> kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:35)
>     at
>
> kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:35)
>     at scala.collection.immutable.Set$Set1.foreach(Set.scala:81)
>     at
>
> kafka.controller.ControllerChannelManager.<init>(ControllerChannelManager.scala:35)
>     at
>
> kafka.controller.KafkaController.startChannelManager(KafkaController.scala:503)
>     at
>
> kafka.controller.KafkaController.initializeControllerContext(KafkaController.scala:467)
>     at
>
> kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:215)
>     at
>
> kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:89)
>     at
> kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:53)
>     at
>
> kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:106)
>     at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
>     at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
>
> i search lot with google, but got nothing help, what should i do? Anyone
> has any ideas?
> sorry for my poor english.
> thanks!
>