Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 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
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!
>

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB