4

カフカ0.8

私はクイックスタートガイドに従い、実行するステップ 2 に来るとbin/kafka-server-start.sh config/server.properties、例外に直面しています:

[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)

私は何が間違っているのでしょうか？お知らせ下さい。

4

1 に答える 1

3

名前解決の問題か、0.7以降の設定が残っている可能性が高いです。

0.7 から移行する場合は、移行ガイドを参照してください。

新たに開始する場合は、/etc/hosts にホスト名の正確なエントリがあることを確認してください。

たとえば、次の/etc/hostnameファイルが与えられた場合

yourhostname

/sbin/ifconfigの例の IP でリッスンするインターフェース ( )10.181.11.14

/etc/hosts は、その名前を listen インターフェースに正しくマップする必要があります。

10.181.11.14    yourhostname.yourdomain.com       yourhostname   someotheralias

kafka ポートに telnet で接続し、タイムアウトがないことを確認してテストできます。

telnet yourhostname.yourdomain.com 9092
Trying 10.181.11.14...
Connected to yourhostname.yourdomain.com.
Escape character is '^]'.
于 2014-02-04T19:50:06.727 に答える