You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by 小宇 <mo...@gmail.com> on 2013/08/07 10:40:00 UTC

Exception with kafka 0.8

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!

Re: Exception with kafka 0.8

Posted by Neha Narkhede <ne...@gmail.com>.
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 <ju...@gmail.com> wrote:

> What's the host/port registered under /brokers/ids/[brokerId] in ZK?
>
> Thanks,
>
> Jun
>
>
> On Wed, Aug 7, 2013 at 1:40 AM, 小宇 <mo...@gmail.com> 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!
> >
>

Re: Exception with kafka 0.8

Posted by Jun Rao <ju...@gmail.com>.
What's the host/port registered under /brokers/ids/[brokerId] in ZK?

Thanks,

Jun


On Wed, Aug 7, 2013 at 1:40 AM, 小宇 <mo...@gmail.com> 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!
>