2台の独立したマシンkafkaを実行するために、2台のマシンlocalhostと192.168.1.110があります。は、消費者またはプロデューサでkafka broker ipを使用できますか?
(1)ローカルホストでは、私が実行します。
➜kafka_2.11-0.10.0.0ビン/ kafka-console-producer.sh --brokerリスト192.168.1.110:9092 --topicテスト この鍵とトピックテストにメッセージを送信するエラーエラー:ヌル値:エラーで2バイト:(org.apache.kafka.clients.producer.internals.ErrorLoggingCallbackメッセージ 【:15 27441 2016年8月24日18]であります) org.apache.kafka.common.errors.TimeoutException:テスト0のブローカからメタデータを要求中にタイムアウトにより1レコードが含まれているバッチ
メッセージをブローカ192.168に送信できない理由1.110? 私は消費者またはプロデューサで直接ブローカーのIPを使用できますか? 私はhostnameだけを使用できましたが、これはadvertised.host.nameに関連していますか? 次に、advertised.host.nameを設定する方法は?このホスト名は世界的に解決できる必要がありません(私はホスト名を解決するには、/ etc/hostsファイルを使用することができます?)
(2) 私はその後、私は実行192.168.1.110、 にlocalhostのポイントをできるように/ etc/hostsファイルを編集しました: ➜kafka_2.11-0.10.0.0 bin/kafka-console-producer.sh --broker-list localhost:9092 --topicテスト
私は正常に192.168.1.110にメッセージを送信し、そこのメッセージを消費することができました。
(3)私は、私が実行192.168.1.110、 にrrlocalhostポイントをできるように/ etc/hostsファイルを編集した: ➜kafka_2.11-0.10.0.0ビン/ kafka-console-producer.sh --brokerリストをrrlocalhost:9092 --topic試験
私は(1)と同じエラーがある、rrlocalhostするメッセージを送りました。