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 <jun...@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, 小宇 <mocking...@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! > > >
