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
The invalid argument exception on a socket connection looks weird. If you
enable debug on kafka.controller.ControllerChannelManager, it will tell you
which broker the newly elected controller is trying to talk to. Then you
will have to make sure that every broker can connect to every other broker.

Thanks,
Neha
On Wed, Aug 7, 2013 at 7:40 AM, Jun Rao <[EMAIL PROTECTED]> wrote:

> 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!
> >
>