スーパーシンプルなシングルインスタンスKafka VMを設定した後に基本エラーが発生します。これは、小規模な量産開発テスト用です。Kafka 0.10.1.0テストサーバー:リクエストMETADATAに失敗しました
これはほとんど最新カフカ0.10.1.0を含む最新コンフルエントプラットフォーム3.1.1を使用しています。
FYI、カフカ0.10.1.1が出ているわずかに新しいバグパッチ、それを含む次ポスト3.1.1コンフルエントプラットフォームバイナリは非常にまだ利用できません。
は、私は(私はdevのテストの簡略化のために静的ローカルIPを使用しています)で/etc/kafka/server.properties
を設定:
listeners=PLAINTEXT://192.168.50.20:9092
advertised.listeners=PLAINTEXT://192.168.50.20:9092
は
シンプルなコンソール管理コマンドがエラーを生成している(?右のことです)。これは、基本的なセットアップ/設定に何か問題があると私に信じさせます。
~$ /usr/bin/kafka-consumer-groups --new-consumer --bootstrap-server localhost:9092 --list
Error while executing consumer group command Request METADATA failed on brokers List(localhost:9092 (id: -1 rack: null))
java.lang.RuntimeException: Request METADATA failed on brokers List(localhost:9092 (id: -1 rack: null))
at kafka.admin.AdminClient.sendAnyNode(AdminClient.scala:67)
at kafka.admin.AdminClient.findAllBrokers(AdminClient.scala:87)
at kafka.admin.AdminClient.listAllGroups(AdminClient.scala:96)
at kafka.admin.AdminClient.listAllGroupsFlattened(AdminClient.scala:117)
at kafka.admin.AdminClient.listAllConsumerGroupsFlattened(AdminClient.scala:121)
at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.list(ConsumerGroupCommand.scala:304)
at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:66)
at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
EDIT:問題、Gondola_Rideのおかげで、私はserver.properties
にlisteners
でIPを指定したということでした。そのIP経由で接続できますが、localhost
では接続できません。ソリューションは、すべてのローカルTCPインタフェースに結合するためのカフカの慣例であるホスト0.0.0.0
を使用していた:
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://192.168.50.20:9092
すごいのではなく、コマンドで直接
ip address
を使用してみてくださいコマンドでそれを使用してみてください! localhostではなくipを使用して、それを修正します!どうして? – clay直接の 'ip address'では、誰に連絡するのかについての混乱はありません。しかし、 'localhost'は利用できないかもしれないマッピングを行っているかもしれません。 '/ etc/hosts'の内容を確認しましたか? – Confused